faust.types.channels
-
class
faust.types.channels.
ChannelT
(app: faust.types.channels._AppT, *, key_type: faust.types.channels._ModelArg = None, value_type: faust.types.channels._ModelArg = None, is_iterator: bool = False, queue: mode.utils.queues.ThrowableQueue = None, maxsize: int = None, root: Optional[faust.types.channels.ChannelT] = None, active_partitions: Set[faust.types.tuples.TP] = None, loop: asyncio.events.AbstractEventLoop = None) → None[source]
-
abstract
clone
(*, is_iterator: bool = None, **kwargs) → faust.types.channels.ChannelT[source]
- Return type
ChannelT
[]
-
abstract
clone_using_queue
(queue: asyncio.queues.Queue) → faust.types.channels.ChannelT[source]
- Return type
ChannelT
[]
-
abstract
stream
(**kwargs) → faust.types.channels._StreamT[source]
- Return type
_StreamT
-
abstract
get_topic_name
() → str[source]
- Return type
str
-
abstract
send_soon
(*, key: Union[bytes, faust.types.core._ModelT, Any, None] = None, value: Union[bytes, faust.types.core._ModelT, Any] = None, partition: int = None, timestamp: float = None, headers: Union[List[Tuple[str, bytes]], Mapping[str, bytes]] = None, key_serializer: Union[faust.types.codecs.CodecT, str, None] = None, value_serializer: Union[faust.types.codecs.CodecT, str, None] = None, callback: Callable[faust.types.tuples.FutureMessage, Union[None, Awaitable[None]]] = None, force: bool = False) → faust.types.tuples.FutureMessage[source]
- Return type
FutureMessage
[]
-
abstract
as_future_message
(key: Union[bytes, faust.types.core._ModelT, Any, None] = None, value: Union[bytes, faust.types.core._ModelT, Any] = None, partition: int = None, timestamp: float = None, headers: Union[List[Tuple[str, bytes]], Mapping[str, bytes]] = None, key_serializer: Union[faust.types.codecs.CodecT, str, None] = None, value_serializer: Union[faust.types.codecs.CodecT, str, None] = None, callback: Callable[faust.types.tuples.FutureMessage, Union[None, Awaitable[None]]] = None) → faust.types.tuples.FutureMessage[source]
- Return type
FutureMessage
[]
-
maybe_declare
[source]
- Return type
None
-
abstract
prepare_key
(key: Union[bytes, faust.types.core._ModelT, Any, None], key_serializer: Union[faust.types.codecs.CodecT, str, None]) → Any[source]
- Return type
Any
-
abstract
prepare_value
(value: Union[bytes, faust.types.core._ModelT, Any], value_serializer: Union[faust.types.codecs.CodecT, str, None]) → Any[source]
- Return type
Any
-
abstract
empty
() → bool[source]
- Return type
bool
-
abstract
on_stop_iteration
() → None[source]
- Return type
None
-
abstract
derive
(**kwargs) → faust.types.channels.ChannelT[source]
- Return type
ChannelT
[]
-
abstract property
subscriber_count
- Return type
int
-
abstract property
queue
- Return type
ThrowableQueue