redditwarp.streaming.makers.message_SYNC

redditwarp.streaming.makers.message_SYNC.get_inbox_message_stream_paginator(client: Client) → CursorPaginator[MailboxMessage]

redditwarp.streaming.makers.message_SYNC.make_inbox_message_stream(paginator: CursorPaginator[MailboxMessage], past: Iterable[MailboxMessage] | None = None) → IStandardStreamEventSubject[MailboxMessage]

redditwarp.streaming.makers.message_SYNC.create_inbox_message_stream(client: Client) → IStandardStreamEventSubject[MailboxMessage]

redditwarp.streaming.makers.message_SYNC.get_mentions_message_stream_paginator(client: Client) → CursorPaginator[CommentMessage]

redditwarp.streaming.makers.message_SYNC.make_mentions_message_stream(paginator: CursorPaginator[CommentMessage], past: Iterable[CommentMessage] | None = None) → IStandardStreamEventSubject[CommentMessage]

redditwarp.streaming.makers.message_SYNC.create_mentions_message_stream(client: Client) → IStandardStreamEventSubject[CommentMessage]