`faust.types.joins`¶

class faust.types.joins.JoinT(*, stream: faust.types.streams.JoinableT, fields: Tuple[faust.types.models.FieldDescriptorT, ...]) → None[source]¶

abstract async process(event: faust.types.events.EventT) → Optional[faust.types.events.EventT][source]¶