faust.transport.utils

class faust.transport.utils.TopicBuffer → None[source]
classmethod map_from_records(records: Mapping[faust.types.tuples.TP, List]) → MutableMapping[str, faust.transport.utils.TopicBuffer][source]
Return type:MutableMapping[str, TopicBuffer[]]
add(tp: faust.types.tuples.TP, buffer: List) → None[source]
Return type:None