[zeromq-dev] odd zmqstream.py behavior

[Steve Huffman]

Hi All,

I'm using pyzmq and zmqstream and have encountered what I think is an error.
My code looks like this:

s = ctx.socket(zmq.PUSH)
s.bind('tcp://127.0.0.1:5555')
self.stream = zmqstream.ZMQStream(s, loop)
self.stream.on_send(echo)

def echo(*a, **kw):
    blah


The on_send callback, echo(), has an deliberate error in it. If an exception
occurs in _run_callback in zmqstream.py, the call to self.close() fails (it
never returns). I've managed to follow this to the eventual call to
zmq_close() in _zmq.pyx/_zmq.c, but don't know enough about zeromq to debug
further.

Thanks,

Steve
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20101001/36c511df/attachment.htm>