Try to address ResourceWarnings

python/custreamz/custreamz/tests/test_dataframes.py

@@ -24,19 +24,23 @@
 
 @pytest.fixture(scope="module")
 def client():
-    client = Client(processes=False, asynchronous=False)
-    try:
+    with Client(processes=False, asynchronous=False) as client:
         yield client
-    finally:
-        client.close()
 
 
-@pytest.fixture(params=["core", "dask"])
-def stream(request, client):
-    if request.param == "core":
-        return Stream()
-    else:
-        return DaskStream()
+@pytest.fixture(scope="module")
+def dask_stream(client):
+    return DaskStream()
+
+
+@pytest.fixture
+def core_stream():
+    return Stream()
+
+
+@pytest.fixture(params=["core_stream", "dask_stream"])
+def stream(request):
+    return request.getfixturevalue(request.param)
 
 
 def test_identity(stream):