faust.types.joins

class faust.types.joins.JoinT(*, stream: JoinableT, fields: Tuple[FieldDescriptorT, ...])[source]
fields: MutableMapping[Type[ModelT], FieldDescriptorT]
stream: JoinableT
abstract async process(event: EventT) → Optional[EventT][source]
Return type:

_GenericAlias[EventT, None]