37
36
class TestMonitoredQueue(BaseZMQTestCase):
41
39
def build_device(self, mon_sub=asbytes(""), in_prefix=asbytes('in'), out_prefix=asbytes('out')):
42
42
self.device = devices.ThreadMonitoredQueue(zmq.PAIR, zmq.PAIR, zmq.PUB,
44
44
alice = self.context.socket(zmq.PAIR)