Implements interfaces: tubes.itube.IFount

The concrete fount type returned by Out.newFount.

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):
ParametersupstreamPauserA Pauser which will pause the upstream fount flowing into our Out.
stopperA 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.

ParametersdrainA drain to fan out values to.
Returnsthe result of drain.flowingFrom
def pauseFlow(self):

Pause the flow.

Returnsa 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.

ParametersitemAn item that the upstream would like to pass on.
API Documentation for tubes, generated by pydoctor at 2016-01-18 07:46:47.