diff --git a/tractor/_streaming.py b/tractor/_streaming.py index 085d994..fb5f8a8 100644 --- a/tractor/_streaming.py +++ b/tractor/_streaming.py @@ -339,7 +339,7 @@ class Context: if self._portal: self._portal._streams.remove(rchan) - async def started(self, value: Any) -> None: + async def started(self, value: Optional[Any] = None) -> None: if self._portal: raise RuntimeError(