diff --git a/piker/clearing/_ems.py b/piker/clearing/_ems.py
index e39c9cdc..aad849aa 100644
--- a/piker/clearing/_ems.py
+++ b/piker/clearing/_ems.py
@@ -161,7 +161,7 @@ async def clear_dark_triggers(
 
     router: Router,
     brokerd_orders_stream: tractor.MsgStream,
-    quote_stream: tractor.ReceiveMsgStream,  # noqa
+    quote_stream: tractor.MsgStream,
     broker: str,
     fqme: str,
 
@@ -177,6 +177,7 @@ async def clear_dark_triggers(
     '''
     # XXX: optimize this for speed!
     # TODO:
+    # - port to the new ringbuf stuff in `tractor.ipc`!
     # - numba all this!
     # - this stream may eventually contain multiple symbols
     quote_stream._raise_on_lag = False