Method __init__

python/proton/_utils.py:157–161

(self, connection: 'Connection', prefetch: int)

    """

    def __init__(self, connection: 'Connection', prefetch: int):
        super(Fetcher, self).__init__(prefetch=prefetch, auto_accept=False)
        self.connection = connection
        self.incoming = collections.deque([])
        self.unsettled = collections.deque([])

    def on_message(self, event: 'Event') -> None:
        self.incoming.append((event.message, event.delivery))