We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
sinks._SourceOfCallable
1 parent 6a89c85 commit 2051ae9Copy full SHA for 2051ae9
src/sghi/etl/commons/sinks.py
@@ -71,7 +71,7 @@ def sink(f: Callable[[_PDT], None]) -> Sink[_PDT]:
71
"""
72
ensure_callable(f, message="A callable object is required.")
73
74
- return _SourceOfCallable(delegate_to=f)
+ return _SinkOfCallable(delegate_to=f)
75
76
77
# =============================================================================
@@ -80,7 +80,7 @@ def sink(f: Callable[[_PDT], None]) -> Sink[_PDT]:
80
81
82
@final
83
-class _SourceOfCallable(Sink[_PDT], Generic[_PDT]):
+class _SinkOfCallable(Sink[_PDT], Generic[_PDT]):
84
__slots__ = ("_delegate_to", "_is_disposed", "_logger")
85
86
def __init__(self, delegate_to: _SinkCallable[_PDT]) -> None:
0 commit comments