tubes.fan._OutFount : API documentation

Method	__init__
Method	flowTo	Flow to the given drain. Don't do anything special; just set up the drain attribute and return the appropriate value.
Method	pauseFlow	Pause the flow.
Method	stopFlow	Invoke the callback supplied to `__init__` for stopping.
Method	_deliverOne	Deliver one item to this fount's drain.

def __init__(self, upstreamPauser, stopper):

Parameters	upstreamPauser	A `Pauser` which will pause the upstream fount flowing into our `Out`.
	stopper	A 0-argument callback to execute on `IFount.stopFlow`

def flowTo(self, drain):

Flow to the given drain. Don't do anything special; just set up the drain attribute and return the appropriate value.

Parameters	drain	A drain to fan out values to.
Returns	the result of `drain.flowingFrom`

def pauseFlow(self):

Pause the flow.

Returns a pause (type: IPause)

def stopFlow(self):

Invoke the callback supplied to __init__ for stopping.

def _deliverOne(self, item):

Deliver one item to this fount's drain.

This is only invoked when the upstream is unpaused.

Parameters item An item that the upstream would like to pass on.

tubes.fan._OutFount(object) class documentation