Skip to content

Commit eef067d

Browse files
authored
Merge pull request #276 from soasme/doc-fix
fix stale docstring in `streamz.unique`.
2 parents d60a6e4 + 588688b commit eef067d

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

streamz/core.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1184,13 +1184,13 @@ class unique(Stream):
11841184
""" Avoid sending through repeated elements
11851185
11861186
This deduplicates a stream so that only new elements pass through.
1187-
You can control how much of a history is stored with the ``history=``
1188-
parameter. For example setting ``history=1`` avoids sending through
1187+
You can control how much of a history is stored with the ``maxsize=``
1188+
parameter. For example setting ``maxsize=1`` avoids sending through
11891189
elements when one is repeated right after the other.
11901190
11911191
Parameters
11921192
----------
1193-
history : int or None, optional
1193+
maxsize: int or None, optional
11941194
number of stored unique values to check against
11951195
key : function, optional
11961196
Function which returns a representation of the incoming data.
@@ -1205,7 +1205,7 @@ class unique(Stream):
12051205
Examples
12061206
--------
12071207
>>> source = Stream()
1208-
>>> source.unique(history=1).sink(print)
1208+
>>> source.unique(maxsize=1).sink(print)
12091209
>>> for x in [1, 1, 2, 2, 2, 1, 3]:
12101210
... source.emit(x)
12111211
1

0 commit comments

Comments
 (0)