Set curSize in ObjQueue()

This commit is contained in:
Dmitri Bogomolov 2021-08-02 21:30:06 +03:00
parent 5c7bbed0f5
commit d01d431833
Signed by untrusted user: g1itch
GPG Key ID: 720A756F18DEED13

View File

@ -18,6 +18,7 @@ class ObjQueue(object):
}
def __init__(self, tag=b'obj'):
self.curSize = 0
context = zmq.Context()
self.socket = context.socket(zmq.SUB)
self.socket.connect('tcp://localhost:5556')