increase coverage

Also remove tests from coverage

.coveragerc

@@ -8,6 +8,7 @@ omit =
     # ignore _version.py and versioneer.py
     .*version.*
     *_version.py
+    */test_*.py
 
 exclude_lines =
     if __name__ == '__main__':

streamz/dataframe.py

@@ -325,17 +325,6 @@ def _accumulate_groupby_mean(accumulator, new, grouper=None, index=None):
     return (sums, counts), sums / counts
 
 
-def _roll(accumulator, new, window, min_periods):
-    accumulator = pd.concat([accumulator, new])
-    if isinstance(window, int):
-        accumulator = accumulator.iloc[-window:]
-    elif isinstance(window, pd.Timedelta):
-        accumulator = accumulator.loc[(accumulator.index.max() - window):]
-
-    out = accumulator if len(accumulator) >= min_periods else []
-    return accumulator, out
-
-
 _subtypes.append((pd.DataFrame, StreamingDataFrame))
 _subtypes.append((pd.Series, StreamingSeries))
 

streamz/tests/test_dataframes.py

@@ -32,6 +32,18 @@ def test_identity():
     assert assert_eq(L2[0], df.x)
 
 
+def test_attributes():
+    df = pd.DataFrame({'x': [1, 2, 3], 'y': [4, 5, 6]})
+    sdf = StreamingDataFrame(example=df)
+
+    assert 'x' in dir(sdf)
+    assert 'z' not in dir(sdf)
+
+    sdf.x
+    with pytest.raises(AttributeError):
+        sdf.z
+
+
 def test_exceptions():
     df = pd.DataFrame({'x': [1, 2, 3], 'y': [4, 5, 6]})
     sdf = StreamingDataFrame(example=df)