diff --git a/captain/tests/test_reactive.py b/captain/tests/test_reactive.py index eb9a7bd..52c3104 100644 --- a/captain/tests/test_reactive.py +++ b/captain/tests/test_reactive.py @@ -33,7 +33,7 @@ def pub(x, id): # TODO: Maybe we should do something like flow.wire() to trigger the # wire process instead of doing it upon construction? - flow = Flow(fc, pub, start_obs) + _ = Flow(fc, pub, start_obs) start_obs.on_next({}) assert outputs["constant1"] == 2