errbot.streaming module

class errbot.streaming.Tee(incoming_stream, clients)[source]

Bases: object

Tee implements a multi reader / single writer

__init__(incoming_stream, clients)[source]

clients is a list of objects implementing callback_stream

run()[source]

streams to all the clients synchronously

start()[source]

starts the transfer asynchronously