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


streams to all the clients synchronously


starts the transfer asynchronously

errbot.streaming.repeatfunc(func, times=None, *args)[source]

Repeat calls to func with specified arguments.

Example: repeatfunc(random.random)

  • args -- params to the function to call.
  • times -- number of times to repeat.
  • func -- the function to repeatedly call.