{io SrSSKJr SSKrSSKrSSKJr SSKJrJ r J r SSK J r \ "SS 5SS j5r \ "S S S SSS5SSSSSS.SSjj5r"SS5r"SS5rg)z,Provide helper classes used by other models.) annotationsN) OrderedDict)AnyCallable Generator)_deprecate_args permissionsknown_permissionscUcS/nOJS/n[U[U5- 5nURSU55 URSU55 SRU5$)aWReturn a comma separated string of permission changes. :param known_permissions: A set of strings representing the available permissions. :param permissions: A list of strings, or ``None``. These strings can exclusively contain ``+`` or ``-`` prefixes, or contain no prefixes at all. When prefixed, the resulting string will simply be the joining of these inputs. When not prefixed, all permissions are considered to be additions, and all permissions in the ``known_permissions`` set that aren't provided are considered to be removals. When ``None``, the result is ``"+all"``. z+allz-allc3,# UH nSU3v M g7f)-N.0xs J/home/james-whalen/.local/lib/python3.13/site-packages/praw/models/util.py %permissions_string..!s/w!!gwc3,# UH nSU3v M g7f)+Nrrs rrr"s3{!!g{r,)sortedsetextendjoin)r r to_setomitteds rpermissions_stringr s`*S-==> /w// 3{33 88F function pause_after skip_existingattribute_nameexclude_beforecontinue_after_idfullnameF)r%r'r&r#r$c +<# Un[SS9n[S5n Sn Sn USLn Sn SnSnUc X-nU S -S -n U(dS U0US '[[U"SS U0UD655H9n[ UU5nUU ;aMSn U R U5 UnU(aM5Uv M; UnSnU (a US:aSv OfU (aUR 5 Sn OLU S - n U (aX:aUR 5 Sn Sv O$[R"UR55 M7f)a Yield new items from ``function`` as they become available. :param function: A callable that returns a :class:`.ListingGenerator`, e.g., :meth:`.Subreddit.comments` or :meth:`.Subreddit.new`. :param attribute_name: The field to use as an ID (default: ``"fullname"``). :param exclude_before: When ``True`` does not pass ``params`` to ``function`` (default: ``False``). :param pause_after: An integer representing the number of requests that result in no new items before this function yields ``None``, effectively introducing a pause into the stream. A negative value yields ``None`` after items from a single response have been yielded, regardless of number of new items obtained in that response. A value of ``0`` yields ``None`` after every response resulting in no new items, and a value of ``None`` never introduces a pause (default: ``None``). :param skip_existing: When ``True``, this does not yield any results from the first request thereby skipping any items that existed in the stream prior to starting the stream (default: ``False``). :param continue_after_id: The initial item ID value to use for ``before`` in ``params``. The stream will continue from the item following this one (default: ``None``). Additional keyword arguments will be passed to ``function``. .. note:: This function internally uses an exponential delay with jitter between subsequent responses that contain no new results, up to a maximum delay of just over 16 seconds. In practice, that means that the time before pause for ``pause_after=N+1`` is approximately twice the time before pause for ``pause_after=N``. For example, to create a stream of comment replies, try: .. code-block:: python reply_function = reddit.inbox.comment_replies for reply in praw.models.util.stream_generator(reply_function): print(reply) To pause a comment stream after six responses with no new comments, try: .. code-block:: python subreddit = reddit.subreddit("test") for comment in subreddit.stream.comments(pause_after=6): if comment is None: break print(comment) To resume fetching comments after a pause, try: .. code-block:: python subreddit = reddit.subreddit("test") comment_stream = subreddit.stream.comments(pause_after=5) for comment in comment_stream: if comment is None: break print(comment) # Do any other processing, then try to fetch more data for comment in comment_stream: if comment is None: break print(comment) To bypass the internal exponential backoff, try the following. This approach is useful if you are monitoring a subreddit with infrequent activity, and you want to consistently learn about new items from the stream as soon as possible, rather than up to a delay of just over sixteen seconds. .. code-block:: python subreddit = reddit.subreddit("test") for comment in subreddit.stream.comments(pause_after=0): if comment is None: continue print(comment) ) max_counteri-rNTFdbeforeparamslimitr) ExponentialCounter BoundedSetreversedlistgetattraddresettimesleepcounter)r"r%r'r&r#r$function_kwargsbefore_attributeexponential_counterseen_attributeswithout_before_counterresponses_without_newvalid_pause_afterfoundnewest_attributer1item attributes rstream_generatorrG&sPB),< oO#4/   #  +E&DNN * II  5  ) +r!)rLrRN)rErreturnbool)rRint)rEr) __name__ __module__ __qualname____firstlineno____doc__rOrSrKr7__static_attributes__rr!rr3r3s ! " (*r!r3c2\rSrSrSrSSjrS SjrSrSrg) r2z6A class to provide an exponential counter with jitter.cSUlXlg)zInitialize an :class:`.ExponentialCounter` instance. :param max_counter: The maximum base value. .. note:: The computed value may be 3.125% higher due to jitter. r-N_base_max)rNr+s rrSExponentialCounter.__init__s  r!cURS- nUR[R"5U--US- - n[URS-UR5UlU$)z?Increment the counter and return the current value with jitter.g0@r)rjrandomminrk)rN max_jittervalues rr;ExponentialCounter.countersQZZ$&  V]]_z99JNJa3  r!cSUlg)zReset the counter to 1.r-N)rj)rNs rr8ExponentialCounter.resets  r!riN)r+r_)r]z int | float) r`rarbrcrdrSr;r8rerr!rr2r2s@  r!r2)r zset[str]r zlist[str] | Noner]str)r"rr%rur'z str | Noner&r^r#z int | Noner$r^r<rr]zGenerator[Any, None, None])rd __future__rrnr9 collectionsrtypingrrrutilr r rGr3r2rr!rrzs2" #++" 34"1A50 %$( ":::" :  :  ::: ::D**:r!