|
- Method resolution order:
- UdpQueueProtocol
- asyncio.protocols.DatagramProtocol
- asyncio.protocols.BaseProtocol
- builtins.object
Methods defined here:
- __init__(self) -> None
- Initialize this protocol.
- datagram_received(self, data: bytes, addr: Tuple[str, int]) -> None
- Handle incoming data.
- error_received(self, exc: Exception) -> None
- Log any received errors.
Data descriptors defined here:
- __dict__
- dictionary for instance variables
- __weakref__
- list of weak references to the object
Data and other attributes defined here:
- __annotations__ = {'conn': <class 'runtimepy.net.connection.Connection'>, 'logger': typing.Union[logging.Logger, logging.LoggerAdapter[typing.Any]]}
Methods inherited from asyncio.protocols.BaseProtocol:
- connection_lost(self, exc)
- Called when the connection is lost or closed.
The argument is an exception object or None (the latter
meaning a regular EOF is received or the connection was
aborted or closed).
- connection_made(self, transport)
- Called when a connection is made.
The argument is the transport representing the pipe connection.
To receive data, wait for data_received() calls.
When the connection is closed, connection_lost() is called.
- pause_writing(self)
- Called when the transport's buffer goes over the high-water mark.
Pause and resume calls are paired -- pause_writing() is called
once when the buffer goes strictly over the high-water mark
(even if subsequent writes increases the buffer size even
more), and eventually resume_writing() is called once when the
buffer size reaches the low-water mark.
Note that if the buffer size equals the high-water mark,
pause_writing() is not called -- it must go strictly over.
Conversely, resume_writing() is called when the buffer size is
equal or lower than the low-water mark. These end conditions
are important to ensure that things go as expected when either
mark is zero.
NOTE: This is the only Protocol callback that is not called
through EventLoop.call_soon() -- if it were, it would have no
effect when it's most needed (when the app keeps writing
without yielding until pause_writing() is called).
- resume_writing(self)
- Called when the transport's buffer drains below the low-water mark.
See pause_writing() for details.
|