switch from PUB to PUSH
This commit is contained in:
@@ -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
|
||||
|
||||
|
||||
Reference in New Issue
Block a user