`faust.types.joins`¶

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

coroutine process(self, event: faust.types.events.EventT) → Union[faust.types.events.EventT, NoneType][source]¶