bad merge

Martin Durant · Martin Durant · commit 4cdb0d7fcca5 · 2021-11-01T16:49:51.000-04:00
diff --git a/streamz/sinks.py b/streamz/sinks.py
@@ -195,6 +195,7 @@ def flush(self, timeout=-1):
         self.producer.flush(timeout)
 
 
+@Stream.register_api()
 class to_websocket(Sink):
     """Write bytes data to websocket
 
