← Back
Editing: zmqstream.cpython-311.pyc
� mc�c�T � �& � d Z ddlZddlZddlmZ ddlmZmZmZm Z m Z mZmZm Z ddlZddlmZmZ ddlmZ ddlmZ dd lmZ ddlZdd lmZ n# e$ rZdd lmZ Y dZ[ndZ[ww xY w ddlmZ n# e$ r Zd� ZY dZ[ndZ[ww xY w G d � d� � ZdS )z�A utility class to send to and recv from a non-blocking socket, using tornado. .. seealso:: - :mod:`zmq.asyncio` - :mod:`zmq.eventloop.future` � N)�Queue)�Any�Callable�List�Optional�Sequence�Union�cast�overload)�POLLIN�POLLOUT)�Literal)�jsonapi� )�gen_log)�IOLoop)�wrapc � � | S �N� )�callbacks �9/usr/lib/python3/dist-packages/zmq/eventloop/zmqstream.py�stack_context_wrapr 2 s � ��� c �� � e Zd ZU dZej ed<