← Back
Editing: posix_pipe.cpython-311.pyc
� �Ïc4 � � � d dl Z e j dk sJ �d dlZd dlmZ d dlmZmZmZm Z ddl m Z ddl m Z dd lmZ d gZ G d � d � � Z G d � d ee � � ZdS )� N�win32)�contextmanager)�ContextManager�Iterator�TextIO�cast� �� DummyContext� )� PipeInput)� Vt100Input�PosixPipeInputc �2 � e Zd ZdZdd�Zdd�Zdd�Zdd�ZdS ) �_PipezCWrapper around os.pipe, that ensures we don't double close any end.�returnNc �b � t j � � \ | _ | _ d| _ d| _ d S )NF)�os�pipe�read_fd�write_fd� _read_closed� _write_closed��selfs �A/usr/lib/python3/dist-packages/prompt_toolkit/input/posix_pipe.py�__init__z_Pipe.__init__ s, � �&(�g�i�i�#�� �d�m� !��� "����� c �X � | j rdS t j | j � � d| _ dS )z!Close read-end if not yet closed.NT)r r �closer r s r � close_readz_Pipe.close_read s2 � � � � � �F� ��� � � � � ����r c �X � | j rdS t j | j � � d| _ dS )z"Close write-end if not yet closed.NT)r r r r r s r � close_writez_Pipe.close_write" s2 � � � � � �F� ��� � � � � !����r c �V � | � � � | � � � dS )z Close both read and write ends.N)r! r# r s r r z _Pipe.close* s* � � ������ �������r �r N)�__name__� __module__� __qualname__�__doc__r r! r# r � r r r r sj � � � � � �I�I�#� #� #� #� !� !� !� !�"� "� "� "�� � � � � r r c �� � � e Zd ZdZdZddededdf� fd� Zee dd ede d fd �� � � � Z d e ddfd �Z d eddfd �Zded fd�Zded fd�Zdd�Zdefd�Z� xZS )r a Input that is send through a pipe. This is useful if we want to send the input programmatically into the application. Mostly useful for unit testing. Usage:: with PosixPipeInput.create() as input: input.send_text('inputdata') r � �_pipe�_textr Nc �$ �� � |� _ G � fd�d� � }t � � � t t |� � � � � � � � |� � � j xj dz c_ � j j � _ d S )Nc �0 �� e Zd ZdZdefd�Zdef� fd� ZdS )�&PosixPipeInput.__init__.<locals>.Stdin�utf-8r c � � dS )NTr* )�stdins r �isattyz-PosixPipeInput.__init__.<locals>.Stdin.isattyE s � ��tr c � �� �j j S �N)r r )r4 r s �r �filenoz-PosixPipeInput.__init__.<locals>.Stdin.filenoH s �� ��y�(�(r N)r& r' r( �encoding�boolr5 �intr8 r s �r �Stdinr1 B sZ �� � � � � � �H� �� � � � � )�� )� )� )� )� )� )� )� )r r< r )r �superr r r � send_text� __class__�_id)r r- r. r< r? s ` �r r zPosixPipeInput.__init__> s� ��� ��� � )� )� )� )� )� )� )� )� )� )� ������f�e�e�g�g�.�.�/�/�/� ���u� � � � ����a� ����>�%����r �textc # � K � t � � } t ||�� � V � |� � � d S # |� � � w xY w)N)r- r. )r r r )�clsrA r s r �createzPosixPipeInput.createR sR � � � � �w�w�� � �t�4�8�8�8� 8� 8� 8� �J�J�L�L�L�L�L��D�J�J�L�L�L�L���s �; �A�datac �D � t j | j j |� � d S r7 )r �writer r �r rE s r � send_byteszPosixPipeInput.send_bytes[ s � � ����#�T�*�*�*�*�*r c �j � t j | j j |� d� � � � dS )zSend text to the input.r2 N)r rG r r �encoderH s r r> zPosixPipeInput.send_text^ s+ � � ����#�T�[�[��%9�%9�:�:�:�:�:r c � � t � � S r7 r r s r �raw_modezPosixPipeInput.raw_modeb � � ��~�~� r c � � t � � S r7 r r s r � cooked_modezPosixPipeInput.cooked_modee rN r c �8 � | j � � � dS )zClose pipe fds.N)r r# r s r r zPosixPipeInput.closeh s � � � � � � � � � � r c � � d| j � �S )z@ This needs to be unique for every `PipeInput`. z pipe-input-)r@ r s r �typeahead_hashz PosixPipeInput.typeahead_hashp s � � (�T�X�'�'�'r )r, r% )r& r' r( r) r@ r �strr � classmethodr r rD �bytesrI r> r rM rP r rS � __classcell__)r? s @r r r 0 s^ �� � � � � � � � �C�&� &�e� &�C� &�� &� &� &� &� &� &�( ��� �#� �x�0@�'A� � � � �^� �[��+�u� +�� +� +� +� +�;�c� ;�d� ;� ;� ;� ;� �.��.� � � � � �^�D� 1� � � � � � � � �(�� (� (� (� (� (� (� (� (r )�sys�platformr � contextlibr �typingr r r r �utilsr �baser �vt100r �__all__r r r* r r �<module>r` s �� � � � � �|�w� � � � � � � � � %� %� %� %� %� %� 9� 9� 9� 9� 9� 9� 9� 9� 9� 9� 9� 9� � � � � � � � � � � � � � � � � � � � �� � � � � � � � �<D(� D(� D(� D(� D(�Z�� D(� D(� D(� D(� D(r
Save File
Cancel