redditwarp.streaming.makers.subreddit_SYNC

redditwarp.streaming.makers.subreddit_SYNC.get_submission_stream_paginator(client: Client, sr: str) → CursorPaginator[Submission]

redditwarp.streaming.makers.subreddit_SYNC.make_submission_stream(paginator: CursorPaginator[Submission], past: Iterable[Submission] | None = None) → IStandardStreamEventSubject[Submission]

redditwarp.streaming.makers.subreddit_SYNC.create_submission_stream(client: Client, sr: str) → IStandardStreamEventSubject[Submission]

redditwarp.streaming.makers.subreddit_SYNC.get_comment_stream_paginator(client: Client, sr: str) → CursorPaginator[LooseComment]

redditwarp.streaming.makers.subreddit_SYNC.make_comment_stream(paginator: CursorPaginator[LooseComment], past: Iterable[LooseComment] | None = None) → IStandardStreamEventSubject[LooseComment]

redditwarp.streaming.makers.subreddit_SYNC.create_comment_stream(client: Client, sr: str) → IStandardStreamEventSubject[LooseComment]

redditwarp.streaming.makers.subreddit_SYNC.get_subreddit_stream_paginator(client: Client) → CursorPaginator[Subreddit]

redditwarp.streaming.makers.subreddit_SYNC.make_subreddit_stream(paginator: CursorPaginator[Subreddit], past: Iterable[Subreddit] | None = None) → IStandardStreamEventSubject[Subreddit]

redditwarp.streaming.makers.subreddit_SYNC.create_subreddit_stream(client: Client) → IStandardStreamEventSubject[Subreddit]