redditwarp.streaming.makers.subreddit_ASYNC

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

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

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

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

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

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

redditwarp.streaming.makers.subreddit_ASYNC.get_subreddit_stream_paginator(client: Client) → CursorAsyncPaginator[Subreddit]

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

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