Merge pull request #328 from roveo/master

pass metadata when using LRU too, fixes #327

Author: martindurant

streamz/core.py

@@ -1409,7 +1409,7 @@ def update(self, x, who=None, metadata=None):
         else:
             if self.seen.get(y, '~~not_seen~~') == '~~not_seen~~':
                 self.seen[y] = 1
-                return self._emit(x)
+                return self._emit(x, metadata=metadata)
 
 
 @Stream.register_api()

streamz/tests/test_core.py

@@ -699,6 +699,15 @@ def test_unique_key():
     assert L == [1, 2, 3]
 
 
+def test_unique_metadata():
+    source = Stream()
+    L = metadata(source.unique()).flatten().sink_to_list()
+    for i in range(5):
+        source.emit(i, metadata=[{'v': i}])
+
+    assert L == [{'v': i} for i in range(5)]
+
+
 def test_unique_history():
     source = Stream()
     s = source.unique(maxsize=2)