bugfix
This commit is contained in:
parent
244c939c9c
commit
4a4ef31418
@ -5,14 +5,11 @@ def handler(b):
|
|||||||
print(b.decode('utf-8'))
|
print(b.decode('utf-8'))
|
||||||
return 'got it'
|
return 'got it'
|
||||||
|
|
||||||
x = ZmqReplier('tcp://127.0.0.1:9999', handler)
|
x = ZmqReplier('tcp://127.0.0.1:5555', handler)
|
||||||
x.run()
|
x.run()
|
||||||
f = 0
|
f = 0
|
||||||
while 1:
|
while 1:
|
||||||
time.sleep(0.1)
|
time.sleep(0.1)
|
||||||
if f==0:
|
|
||||||
print(dir(x.sock.get_peer()))
|
|
||||||
f += 1
|
|
||||||
|
|
||||||
x.stop()
|
x.stop()
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user