diff --git a/dap/utils/bsreadext.py b/dap/utils/bsreadext.py index 185ead2..5843428 100644 --- a/dap/utils/bsreadext.py +++ b/dap/utils/bsreadext.py @@ -1,12 +1,12 @@ import numpy as np -from bsread import Sender, PUB +from bsread import Sender, PUSH def make_bsread_sender(host="*", port=None): if not port: return None address = f"tcp://{host}" - sender = Sender(address=address, port=port, block=False, mode=PUB) + sender = Sender(address=address, port=port, block=False, mode=PUSH) sender.open() return sender