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

start() Thread[source]

starts the transfer asynchronously

errbot.streaming.repeatfunc(func: Callable[[...], None], times: int | None = 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.