MTN: lossless_combine_latest -> zip_latest to match streamz

xpdAcq · Aug 18, 2017 · 30d0ea4 · 30d0ea4
1 parent 6d0200b
commit 30d0ea4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/shed/event_streams.py b/shed/event_streams.py
@@ -1048,7 +1048,7 @@ def update(self, x, who=None):
             return self.emit(tup)
 
 
-class lossless_combine_latest(EventStream):
+class zip_latest(EventStream):
     """Combine multiple streams together to a stream of tuples
 
     This will emit a new tuple of the elements from the lossless stream paired
@@ -1072,7 +1072,7 @@ class lossless_combine_latest(EventStream):
     >>> gg = to_event_model(b, [('det', {'dtype': 'float'})])
     >>> source = Stream()
     >>> source2 = Stream()
-    >>> m = es.lossless_combine_latest(source, source2)
+    >>> m = es.zip_latest(source, source2)
     >>> l = m.sink(print)
     >>> L = m.sink_to_list()
     >>> for doc1 in g: zz = source.emit(doc1)

diff --git a/shed/tests/test_streams.py b/shed/tests/test_streams.py
@@ -772,7 +772,7 @@ def test_lossless_combine_latest(exp_db, start_uid1, start_uid3):
     source = Stream()
     source2 = Stream()
 
-    L = es.lossless_combine_latest(source, source2).sink_to_list()
+    L = es.zip_latest(source, source2).sink_to_list()
     ih1 = exp_db[start_uid1]
     ih2 = exp_db[start_uid3]
     s = exp_db.restream(ih1)
@@ -796,7 +796,7 @@ def test_lossless_combine_latest_reverse(exp_db, start_uid1, start_uid3):
     source = Stream()
     source2 = Stream()
 
-    L = es.lossless_combine_latest(source, source2).sink_to_list()
+    L = es.zip_latest(source, source2).sink_to_list()
     ih1 = exp_db[start_uid1]
     ih2 = exp_db[start_uid3]
     s = exp_db.restream(ih1)