tubes.listening.Listener : API documentation

Method	__init__
Method	flowingFrom	The flow has begun from the given `fount` of `Flow`s.
Method	receive	Receive the given flow, applying backpressure if too many connections are active.
Method	flowStopped	No more `Flow`s are incoming; nothing to do.

def __init__(self, flowConnector, maxConnections=100):

Parameters	flowConnector	a 1-argument callable taking a `Flow` and returning nothing, which connects the flow.
	maxConnections	The number of concurrent `Flow` objects to maintain active at once. (type: `int`)

def flowingFrom(self, fount):

The flow has begun from the given fount of Flows.

Parameters	fount	A fount of flows. One example of such a suitable fount would be the return value of `tubes.protocol.flowFountFromEndpoint`.
Returns	`None`, since this is a "terminal" drain, where founts of `Flow` must end up in order for more new connections to be established.

def receive(self, item):

Receive the given flow, applying backpressure if too many connections are active.

Parameters item The inbound Flow.

def flowStopped(self, reason):

No more Flows are incoming; nothing to do.

Parameters reason the reason the flow stopped.

tubes.listening.Listener(object) class documentation