Call a callback when the flow stops.

Method __init__ Call the given callback.
Method received Pass through all received items.
Method stopped Call the callback on stop.
def __init__(self, callback):

Call the given callback.

def received(self, item):

Pass through all received items.

ParametersitemAn item being passed through (type unknown).
def stopped(self, reason):

Call the callback on stop.

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