errbot.streaming module

classerrbot.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() → 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)

Parameters:

  • args – params to the function to call.

  • times – number of times to repeat.

  • func – the function to repeatedly call.