U
|
Z ±dù ã
|
@ sî U d dl Z d dlZd dlmZmZmZ d dlZddlmZm Z ddl
|
m Z m Z dZ ee ed< dZee ed< erG dd d e ZG d
|
d d e Zd dd ddZed ef dddZed ef dddZzTejdkrèddlmZ n8ejdkreseedrddlmZ n ddlmZ W n( ek
|
rJ Z ze Z W 5 dZ [ X Y nX zterVnhe j dkrtdd Zd d ZnJe j d kr¶dd l m Z m Z d d l!m"Z# d dl$Z$d d Zd!d Zned"W n( ek
|
rè Z ze ZW 5 dZ [ X Y nX dS )#é N)ÚOptionalÚTupleÚ TYPE_CHECKINGé )Ú_coreÚ _subprocess)Ú
|
SendStreamÚ ReceiveStreamÚ_wait_child_exiting_errorÚ_create_child_pipe_errorc @ s e Zd ZddddZdS )ÚClosableSendStreamN©Úreturnc C s d S ©N© ©Úselfr r úYd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_subprocess_platform/__init__.pyÚclose s zClosableSendStream.close©Ú__name__Ú
|
__module__Ú __qualname__r r r r r r s r c @ s e Zd ZddddZdS )ÚClosableReceiveStreamNr c C s d S r r r r r r r s zClosableReceiveStream.closer r r r r r s r z_subprocess.Process)Úprocessr c à s
|
t tdS )aî Block until the child process managed by ``process`` is exiting.
|
|
It is invalid to call this function if the process has already
|
been waited on; that is, ``process.returncode`` must be None.
|
|
When this function returns, it indicates that a call to
|
:meth:`subprocess.Popen.wait` will immediately be able to
|
return the process's exit status. The actual exit status is not
|
consumed by this call, since :class:`~subprocess.Popen` wants
|
to be able to do that itself.
|
N)ÚNotImplementedErrorr
|
)r r r r Úwait_child_exiting s r r c C s
|
t tdS )ap Create a new pipe suitable for sending data from this
|
process to the standard input of a child we're about to spawn.
|
|
Returns:
|
A pair ``(trio_end, subprocess_end)`` where ``trio_end`` is a
|
:class:`~trio.abc.SendStream` and ``subprocess_end`` is
|
something suitable for passing as the ``stdin`` argument of
|
:class:`subprocess.Popen`.
|
N©r r r r r r Úcreate_pipe_to_child_stdin, s
|
r c C s
|
t tdS )a Create a new pipe suitable for receiving data into this
|
process from the standard output or error stream of a child
|
we're about to spawn.
|
|
Returns:
|
A pair ``(trio_end, subprocess_end)`` where ``trio_end`` is a
|
:class:`~trio.abc.ReceiveStream` and ``subprocess_end`` is
|
something suitable for passing as the ``stdin`` argument of
|
:class:`subprocess.Popen`.
|
Nr r r r r Ú create_pipe_from_child_output9 s r Úwin32é )r ÚlinuxZ wait_keventÚposixc C s t ¡ \} }tj |¡| fS r ©ÚosÚpipeÚtrioZlowlevelZFdStream©ZrfdZwfdr r r r X s c C s t ¡ \} }tj | ¡|fS r r$ r( r r r r \ s Únt)ÚPipeSendStreamÚPipeReceiveStream)r& c C s$ t dd\} }t|t | tj¡fS )N)FT©Z
|
overlapped)Ú windows_piper* ÚmsvcrtÚopen_osfhandler% ÚO_RDONLY©ZrhZwhr r r r l s c C s" t dd\} }t| t |d¡fS )N)TFr, r )r- r+ r. r/ r1 r r r r q s z&pipes not implemented on this platform)%r% ÚsysÚtypingr r r r' Ú r r Ú_abcr r r
|
Ú ImportErrorÚ__annotations__r r r r Úintr r ÚplatformZwindowsÚhasattrZkqueueZwaitidÚexÚnameZ_windows_pipesr* r+ Zasyncio.windows_utilsr& r- r. r r r r Ú<module> sJ
|
|
|
|
