| | |
- asyncio.protocols.Protocol(asyncio.protocols.BaseProtocol)
-
- QueueProtocol(runtimepy.net.mixin.BinaryMessageQueueMixin, asyncio.protocols.Protocol)
- runtimepy.net.mixin.BinaryMessageQueueMixin(builtins.object)
-
- QueueProtocol(runtimepy.net.mixin.BinaryMessageQueueMixin, asyncio.protocols.Protocol)
class QueueProtocol(runtimepy.net.mixin.BinaryMessageQueueMixin, asyncio.protocols.Protocol) |
| |
QueueProtocol() -> 'None'
A simple streaming protocol that populates a message queue.
|
| |
- Method resolution order:
- QueueProtocol
- runtimepy.net.mixin.BinaryMessageQueueMixin
- asyncio.protocols.Protocol
- asyncio.protocols.BaseProtocol
- builtins.object
Methods defined here:
- connection_lost(self, exc: Optional[Exception]) -> None
- Log the disconnection.
- connection_made(self, transport: asyncio.transports.BaseTransport) -> None
- Log the connection establishment.
- data_received(self, data: Union[bytes, bytearray, memoryview]) -> None
- Handle incoming data.
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 runtimepy.net.mixin.BinaryMessageQueueMixin:
- __init__(self) -> 'None'
- Initialize this protocol.
Data descriptors inherited from runtimepy.net.mixin.BinaryMessageQueueMixin:
- __dict__
- dictionary for instance variables
- __weakref__
- list of weak references to the object
Methods inherited from asyncio.protocols.Protocol:
- eof_received(self)
- Called when the other end calls write_eof() or equivalent.
If this returns a false value (including None), the transport
will close itself. If it returns a true value, closing the
transport is up to the protocol.
Methods inherited from asyncio.protocols.BaseProtocol:
- 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.
| |