]Og&*SSKrSSKrSSKrSSKrSSKJrJrJrJ r J r SSK J r \R(aSSKJr \R \\ /\4r\R \R$\/\4r"SS\R(\\R$\5rg)N)RTT_coUU_co)NotSetOptionalc .\rSrSrSrSMS\R \R\SS4Sjjr SNSjr S\4S jr \RS \ SS4S j5r\RS \S\4S j5rS rS\4SjrS\R\SS4Sjr\RS\SS4Sj5r\RS\S\\\4SS4Sj5rSMSjrS\R*\/\4SS4SjrSSS\R0S\R0SS4Sjr\RS\R4\4S j5r\RS\\\4S\4S!j5r\4S"jrS\4S#jr\RSOS$j5r\RSPS&j5rS'rSMS\R \SS4S(jjrSQS)\R \R*\/\R04S*\R@\RB\\RD\S4SS4S+jjr#S\R*\/\4SS4S,jr$SRS-jr%S\R*\/\4SS4S.jr&S\R \4S/jr'SSS0jr(S1\R*\/\R\4SS4S2jr)\RS)\R*\/\4SS34S4j5r*\RS)\R*\/\4S\R*\R\/\+4SS54S6j5r*SMS)\R*\/\+4S\R \\\44S7jjr*S1\R*\/\4SS4S8jr,S9\RZ\.SS:4S;jr/\RS<\0\\4S\4S=j5r1\RS<\0\\4S>\S\4S?j5r1\2Rf4S@jr1\RSA\SS4SBj5r \RSTSC\SA\SD\SS4SEjj5r SQSFjr SUSG\R@\4\R*\/\R044SH\SS4SIjjr5SUSS%SH\SS%4SJjjr6S\R*\/\4SS4SKjr7SLr8g)VStreamz? A stream is an iterable with utility methods to transform it. Niterablereturnc:UcSn[U5UlXlg)N)iter_it _original)selfrs S/Users/admin/workspace/ai/Jarvis/env/lib/python3.13/site-packages/nr/util/stream.py__init__Stream.__init__shH~DH3;N Stream[T_co]cU$Nrrs r__iter__Stream.__iter__s Krc:SUl[UR5$r)rnextrrs r__next__Stream.__next__sDN >rvalcgrrrr$s r __getitem__Stream.__getitem__#s7:rcgrrr&s rr'r(&s+.rc6[U[5(a1URURURUR5$[U[ 5(aUS:a7[ U5Hup#X!:XdM Us $ [SRU55e[R"U[U5S9n[U5[U5:a[SRU55eUS$[SR[U5R55e)Nrz$Stream has no element at position {})maxlenz+{} object is only subscriptable with slices) isinstanceslicestartstopstepint enumerate IndexErrorformat collectionsdequeabslen TypeErrortype__name__)rr$indexvaluequeues rr'r()s#u ZZ 388SXX 66 C   %dOLE \L,?FFsKLL!!$s3x8 u:C AHHMN NQx CJJ4PT:K^K^_ ``rc,[UR5$r)r!rrs rr! Stream.next:s >ritscV[[R"UR/UQ765$r)r itertoolschainr)rrAs rappend Stream.append=s )//$((1S1 22rnzStream[t.List[T_co]]cgrr)rrGs rbatch Stream.batch@s58r collectorz Stream[R]cgrr)rrGrKs rrIrJCsILrc^^^^[UR5mTc[mUU4SjmUUU4Sjn[U"55$)z Convert the stream into a stream of batches of size *n*, where each element of the stream contains the result of the *collector* after passing up to *n* elements of the original stream into it. c3~># Uv SnUT:a[T5v US- nUT:aMgg![a gf=f7f)Nr! StopIteration)firstcountrrGs rtakeStream.batch..takeQsM ke AI X    AI   s = - == :=:=c3j># [T5nT"T"U55v M![a gf=f7frrP)rRrKrrTs rgenerate_batches&Stream.batch..generate_batches[s@  x.%U $$    s3 #3 0303)rrlistr )rrGrKrWrrTs `` @@rrIrJFs8DHH~Hi% "$ %%r predicatez#t.Tuple[Stream[T_co], Stream[T_co]]c[R"UR5up#[[R"X55[[ X554$)z Use a predicate to partition items into false and true entries. Returns a tuple of two streams with the first containing all elements for which *pred* returned #False and the other containing all elements where *pred* returned #True. )rCteerr filterfalsefilter)rrZt1t2s r bipartitionStream.bipartitiones=]]488 $FB )'' 6 7y@U9V VVrrzStream[t.Callable[..., R]]akwcF^^[UU4SjUR55$)z> Calls every item in *iterable* with the specified arguments. c32># UH o"T0TD6v M g7frr).0xrcrds r Stream.call..us0x!!Q+"+xsr r)rrcrds ``rcall Stream.callps 0txx0 00rcgrrrs rcollectStream.collectws%(rcgrrrrKs rrorpzs9# TH3n[R"[RU5HnUv M M5 g7fr)tcastIterable)itelementrs r generator Stream.concat..generators."vvajj"-G-.s;>)r )rrs` rryrzs  )+ rcUb+[U5Hn[UR5 M U$[UR5 M![a  U$f=f![a U$f=f)zV Consume the contents of the stream, up to *n* elements if the argument is specified. )ranger!rrQ)rrG_s rconsumeStream.consumes{  }Qx!  txx. K   txx.    K     K s"AA AA A('A(keyskipc^^^UcSmOUmS[R[SS44UUU4Sjjn[U"55$)aB Yields unique items from *iterable* whilst preserving the original order. If *skip* is specified, it must be a set or sequence of items to skip in the first place (ie. items to exclude from the returned stream). The specified set/sequence is modified in-place. Using a set is highly recommended for performance purposes. NcU$rrrhs r!Stream.distinct..s1rrc3># Tc [5OTn[U[R5(a URO UR nUR nTRH&nT"U5nU"U5(aMU"U5 Uv M( g7fr)setr,r MutableSetaddrE __contains__r)seen mark_visited check_visiteditemkey_valkey_funcrrs rr"Stream.distinct..generatorsllSUd!+D!,,!?!?TXXT[[l''m(($4.W%% w * s A5B <B )r Generatorrr )rrrrrs` ` @rdistinctStream.distinctsD {hhq{{4t#34 )+ rcT[[R"XR55$r)r rC dropwhilerrrZs rrStream.dropwhile )%%i: ;;rc:[SUR55$)Nc3.# UH ocMUv M g7frr)rgrhs rri"Stream.dropnone..s7X!!Xs rkrs rdropnoneStream.dropnones 7TXX7 77rcB^[U4SjUR55$)z4 Agnostic to Python's built-in `filter()` function. c3F># UHnT"U5(dMUv M g7frr)rgrhrZs rri Stream.filter..s6X1!!Xs! !rkrs `rr^ Stream.filters 6TXX6 66rcDUR5$![a gf=f)z5 Returns the first element of the stream, or `None`. NrPrs rrR Stream.firsts%  YY[  s  c:SSKJn U"UR55$)z; Returns the first element of the stream as an `Optional`. rr )nr.util.optionalr rR)rr s rfirstoptStream.firstopts * DJJL !!rfunccl^^S[R[SS44UU4Sjjn[U"55$)z) Same as #map() but flattens the result. rNc3Z># TRHnT"U5HnUv M M g7fr)r)rhyrrs rr!Stream.flatmap..generators'xx!aA's(+)rrrr )rrrs`` rflatmapStream.flatmaps2 q{{1dD=1 )+ rz$Stream[t.Tuple[R, t.Iterable[T_co]]]cgrr)rrs rgroupbyStream.groupbys[^rzStream[t.Tuple[R, U]]cgrr)rrrKs rrrsz}rc^^^Tc*[[R"TRT55$UUU4Sjn[U"55$)Nc3># Tce[R"TRT5HupUT"U54v M g7fr)rCrr)kgrKrrs rr!Stream.groupby..generator s=$$$%%dhh4DA9Q< 5s=A)r rCrr)rrrKrs``` rrr s9 I%%dhh4 55 IK  rcB^[U4SjUR55$)z1 Agnostic to Python's built-in `map()` function. c34># UH nT"U5v M g7frr)rgrhrs rriStream.map..s,8a$q''8srk)rrs `rmap Stream.maps ,488, ,,rr:z Stream[U_co]cB^[U4SjUR55$)z Filters using #isinstance(). c3N># UHn[UT5(dMUv M g7fr)r,)rgrhr:s rri!Stream.of_type.. s=XAt)[U[R5(aUT$[UT5$r)r,rMappinggetattr)r lookup_attrs rrStream.sortby..byDs, dAII & &k" "{+ +r)rr) r,strrrCallablerAnyr sortedr)rrrrs @rsortby Stream.sortby7sW"ck,  D6155=)2 .B &r; <.Nsr)r)rrs rsort Stream.sortMs ;;{G ,,rcT[[R"XR55$r)r rC takewhilerrs rrStream.takewhilePrr)rrr)rr)rx Stream[str]rr)rxzStream[t.Iterable[T]]rr|)NN)rzStream[t.Optional[T_co]]rr)rzOptional[T_co])rO)F)9r; __module__ __qualname____firstlineno____doc__rr rrrrr"overloadr-r'r1r!rErI CollectorrrboolrarrlListrorYrSryrUnionrMutableSequencerrrr^rRrrrrrTyperr Aggregatorrrrrrrr__static_attributes__rrrr r s W1::tfdl#; W@e W1-115511+1::(qvvd|((::7QZZ%" !**dVQZZ]%:;  ::^TFAI.^3Y^^::}TFAI.}1::qzzRVGWFXZ[F[;\}ax}} !TFAI. !1::iPTVWPWFX;Y !-ajj$+- ->!&&,>>>::Cz$*5C$CC::Iz!T'2IQI1II'-||= ::3333::NNCNsN>NNA=qwwsAJJvquu}$==>==Zh=,--t- -<TFDL!9r sx//$??' ZZA " JJ 1 ) * @