Implements interfaces: tubes.itube.IFount

An IFount that wraps around an ITransport, and, with the help of a _ProtocolPlumbing, delivers any data received by that ITransport to an IDrain.

Method __init__ Undocumented
Method flowTo Start delivering data from the transport to the given drain.
Method pauseFlow Pause flowing.
Method stopFlow End the flow from this fount, dropping the TCP connection in the process.
Instance Variable _transport the transport. (type: provider of ITransport and IProducer.)
Instance Variable _pauser a pauser that will pause and resume the transport. (type: Pauser)
Instance Variable _preReceivePause If data is received from the protocol when no drain is connected, this will be an IPause. (type: IPause or types.NoneType)
Instance Variable _preReceiveBuffer If data is received from the protocol when no drain is connected, then this will be the bytes. (type: bytes or types.NoneType)
_transport =
the transport. (type: provider of ITransport and IProducer.)
_pauser =
a pauser that will pause and resume the transport. (type: Pauser)
_preReceivePause =
If data is received from the protocol when no drain is connected, this will be an IPause. (type: IPause or types.NoneType)
_preReceiveBuffer =
If data is received from the protocol when no drain is connected, then this will be the bytes. (type: bytes or types.NoneType)
def __init__(self, transport):
Undocumented
def flowTo(self, drain):

Start delivering data from the transport to the given drain.

Parametersdrainthe drain that will receive data from the wrapped transport.
Returnsthe next fount in the chain.
def pauseFlow(self):

Pause flowing.

Returnsa pause token.
def stopFlow(self):

End the flow from this fount, dropping the TCP connection in the process.

API Documentation for tubes, generated by pydoctor at 2016-01-18 07:46:47.