Skip to content

Commit d4bb082

Browse files
committed
Fix typo in the last example
1 parent f639529 commit d4bb082

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

streamz/core.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1324,7 +1324,7 @@ class timed_window_unique(Stream):
13241324
()
13251325
13261326
Get unique elements in a window by (string) length, keeping just the last occurrence:
1327-
>>> stream = source.timed_window_unique(interval=1.0, key=len, keep="first")
1327+
>>> stream = source.timed_window_unique(interval=1.0, key=len, keep="last")
13281328
>>> for ele in ["f", "b", "fo", "ba", "foo", "bar"]:
13291329
... source.emit(ele)
13301330
()

0 commit comments

Comments
 (0)