i, %SSKJr SSKrSSKrSSKrSSKJrJr SSK r SSK J r SSK J r Jr \(a\RS:wdeSrS \S '"S S 5r\"S S\ 55rg)) annotationsN) TYPE_CHECKINGFinal)Stream)ConflictDetectorfinalwin32i FinalTypeDEFAULT_RECEIVE_SIZEc\\rSrSr%S\S'S Sjr\S Sj5rS SjrS Sjr S Sjr S r g ) _FdHolderintfdcSUl[U[5(d [S5eXl[R "U5Ul[R"US5 g)Nzfile descriptor must be an intF)r isinstancer TypeErroros get_blocking_original_is_blocking set_blockingselfrs =C:\des-py\RoboSAPF\venv\Lib\site-packages\trio/_unix_pipes.py__init___FdHolder.__init__(sH"c""<= =%'__R%8" E"c URS:H$Nr)rrs rclosed_FdHolder.closed3sww"}rcUR(agURnSUl[R"XR5 [R "U5 gr!)r#rrrrclosers r _raw_close_FdHolder._raw_close7s; ;;  WW 667  rc$UR5 gN)r'r"s r__del___FdHolder.__del__Fs  rcUR(d:[RRUR5 UR 5 ggr*)r#triolowlevelnotify_closingrr'r"s rr&_FdHolder.closeIs.{{ MM ( ( 1 OO r)rrNrrreturnNone)r3boolr3r4) __name__ __module__ __qualname____firstlineno____annotations__rpropertyr#r'r+r&__static_attributes__rrrrs1$ G # rrcb\rSrSrSrS SjrS SjrSSjrSSSjjrSSjr SS jr SS jr S r g)FdStreamOaRepresents a stream given the file descriptor to a pipe, TTY, etc. *fd* must refer to a file that is open for reading and/or writing and supports non-blocking I/O (pipes and TTYs will work, on-disk files probably not). The returned stream takes ownership of the fd, so closing the stream will close the fd too. As with `os.fdopen`, you should not directly use an fd after you have wrapped it in a stream using this function. To be used as a Trio stream, an open file must be placed in non-blocking mode. Unfortunately, this impacts all I/O that goes through the underlying open file, including I/O that uses a different file descriptor than the one that was passed to Trio. If other threads or processes are using file descriptors that are related through `os.dup` or inheritance across `os.fork` to the one that Trio is using, they are unlikely to be prepared to have non-blocking I/O semantics suddenly thrust upon them. For example, you can use ``FdStream(os.dup(sys.stdin.fileno()))`` to obtain a stream for reading from standard input, but it is only safe to do so with heavy caveats: your stdin must not be shared by any other processes, and you must not make any calls to synchronous methods of `sys.stdin` until the stream returned by `FdStream` is closed. See `issue #174 `__ for a discussion of the challenges involved in relaxing this restriction. .. warning:: one specific consequence of non-blocking mode applying to the entire open file description is that when your program is run with multiple standard streams connected to a TTY (as in a terminal emulator), all of the streams become non-blocking when you construct an `FdStream` for any of them. For example, if you construct an `FdStream` for standard input, you might observe Python loggers begin to fail with `BlockingIOError`. Args: fd (int): The fd to be wrapped. Returns: A new `FdStream` object. cd[U5Ul[S5Ul[S5Ulg)Nz*another task is using this stream for sendz-another task is using this stream for receive)r _fd_holderr_send_conflict_detector_receive_conflict_detectorrs rrFdStream.__init__ys/#B-'7 8( $+; ;+ 'rc^# UR URR(a[R"S5e[R R 5IShvN [U5n[U5nSnXB:aCX4SnU[R"URRU5- nSSS5 XB:aMCSSS5 SSS5 gNv![a? [R RURR5IShvN Nj[aKnUR[R :Xa[R"S5Se[R"UeSnAff=f!,(df  N=f!,(df  N=f!,(df  g=f7f)Nfile was already closedr)rDrCr#r.ClosedResourceErrorr/ checkpointlen memoryviewrwriterBlockingIOError wait_writableOSErrorerrnoEBADFBrokenResourceError)rdatalengthviewsent remaininges rsend_allFdStream.send_alls?  ) )%%../HII--**, , ,YFD!Tme  F BHHT__-?-?$KKD%m"* ) - /R"&--"="=doo>P>P"QQQ&F ww%++5&*&>&>$='"'+!,'+&>&>A E F %"!* )s F-AF"C#F= F  E: .C9 F F F-FAE7 D E7 !E:# E7 ,AE2 2E7 7E:: F F  F F F*&F-c4# UR URR(a[R"S5e[R R URR5IShvN SSS5 gN !,(df  g=f7f)NrH)rDrCr#r.rIr/rOrr"s rwait_send_all_might_not_block&FdStream.wait_send_all_might_not_blockse  ) )%%../HII----doo.@.@A A A* ) B* )s/ BA(B7B8B< BB BBNc# UR Uc[nO1[U[5(d [ S5eUS:a [ S5e[ RR5IShvN [R"URRU5nUsSSS5 $N=![a? [ RRURR5IShvN OW[aKnUR [ R":Xa[ R$"S5Se[ R&UeSnAff=fM!,(df  g=f7f)Nzmax_bytes must be integer >= 1rrH)rEr rrr ValueErrorr.r/rJrreadrCrrN wait_readablerPrQrRrIrS)r max_bytesrTexcs r receive_someFdStream.receive_somes  , , 0 !)S11#$DEEq=$%EFF--**, , , 774??#5#5yAD3- , -'J--55doo6H6HIII@yyEKK/"665#$#66C? @ - ,sm EAE ,B*-E 3+B,E  E*E ,AE,C/-E2E 4 E=AEEE  EEc8URR5 gr*)rCr&r"s rr&FdStream.closes rc|# UR5 [RR5IShvN gN7fr*)r&r.r/rJr"s racloseFdStream.acloses$ mm&&(((s 2<:<c.URR$r*)rCrr"s rfilenoFdStream.filenos!!!r)rCrErDr2)rTbytesr3r4r6r*)rcz int | Noner3ro)r3r) r7r8r9r:__doc__rrZr]rer&rjrmr=r>rrr@r@Os-&P F2B 8 )"rr@) __future__rrQrsystypingrrr r._abcr_utilrr platformr r;rr@r>rrrwsg" 4 * CLLG333#(i'88vu"vu"u"r