runtimepy.net.udp.protocol
index
/home/vkottler/src/vkottler/workspace/runtimepy/runtimepy/net/udp/protocol.py

A module implementing a DatagramProtocol for UdpConnection.

 
Modules
       
asyncio

 
Classes
       
asyncio.protocols.DatagramProtocol(asyncio.protocols.BaseProtocol)
UdpQueueProtocol

 
class UdpQueueProtocol(asyncio.protocols.DatagramProtocol)
    UdpQueueProtocol() -> None
 
A simple UDP protocol that populates a message queue.
 
 
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.