Supplier¶

class softs.Supplier[source]¶

__init__(generator_fn, product_ids, endpoint, medium_cls, slot_size, send_timeout_ms=10000)[source]¶

Parameters:

generator_fn (Callable[[str], bytes])
product_ids (list[str])
endpoint (str)
medium_cls (type[Medium])
slot_size (int)
send_timeout_ms (int)

start()[source]¶

Return type:: None

stop()[source]¶

Return type:: None