Implements interfaces: tubes.itube.IDrain

The one of the drains associated with an fan.In.

Method __init__ Create an _InDrain with an In.
Method flowingFrom The attached In is now receiving inputs from the given fount.
Method receive Pass along any received item to the drain that the In's fount is flowing to.
Method flowStopped Remove this drain from its attached In.
def __init__(self, fanIn):

Create an _InDrain with an In.

def flowingFrom(self, fount):

The attached In is now receiving inputs from the given fount.

ParametersfountAny fount.
ReturnsNone; this is a terminal drain and not a data-processing drain.
def receive(self, item):

Pass along any received item to the drain that the In's fount is flowing to.

Parametersitemany object
Returnspassed through from the active drain.
def flowStopped(self, reason):

Remove this drain from its attached In.

Parametersreasonthe reason the flow stopped.
API Documentation for tubes, generated by pydoctor at 2016-01-18 07:46:47.