'Wrap running callbacks in try/except to allow us to
close our socket.'

def _run_callback(self, callback, *args, **kwargs):

    try:
        with stack_context.NullContext():
            callback(*args, **kwargs)
    except:
        gen_log.error('Uncaught    exception    in    ZMQStream    callback', exc_info=True)
        raise
