`redditwarp.streaming.makers.message_ASYNC`#

redditwarp.streaming.makers.message_ASYNC.get_inbox_message_stream_paginator(client: Client) → CursorAsyncPaginator[MailboxMessage][source]#

redditwarp.streaming.makers.message_ASYNC.make_inbox_message_stream(paginator: CursorAsyncPaginator[MailboxMessage], past: Iterable[MailboxMessage] | None = None) → IStandardStreamEventSubject[MailboxMessage][source]#

redditwarp.streaming.makers.message_ASYNC.create_inbox_message_stream(client: Client) → IStandardStreamEventSubject[MailboxMessage][source]#

redditwarp.streaming.makers.message_ASYNC.get_mentions_message_stream_paginator(client: Client) → CursorAsyncPaginator[CommentMessage][source]#

redditwarp.streaming.makers.message_ASYNC.make_mentions_message_stream(paginator: CursorAsyncPaginator[CommentMessage], past: Iterable[CommentMessage] | None = None) → IStandardStreamEventSubject[CommentMessage][source]#

redditwarp.streaming.makers.message_ASYNC.create_mentions_message_stream(client: Client) → IStandardStreamEventSubject[CommentMessage][source]#