redditwarp.streaming.makers.user_SYNC

redditwarp.streaming.makers.user_SYNC.get_user_subreddit_stream_paginator(client: Client) → CursorPaginator[Subreddit]

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

redditwarp.streaming.makers.user_SYNC.create_user_subreddit_stream(client: Client) → IStandardStreamEventSubject[Subreddit]