`redditwarp.streaming.makers.user_ASYNC`#

redditwarp.streaming.makers.user_ASYNC.get_user_subreddit_stream_paginator(client: Client) → CursorAsyncPaginator[Subreddit][source]#

redditwarp.streaming.makers.user_ASYNC.make_user_subreddit_stream(paginator: CursorAsyncPaginator[Subreddit], past: Iterable[Subreddit] | None = None) → IStandardStreamEventSubject[Subreddit][source]#

redditwarp.streaming.makers.user_ASYNC.create_user_subreddit_stream(client: Client) → IStandardStreamEventSubject[Subreddit][source]#