文件操作 - _producer_helpers.cpython-310.pyc
返回文件管理
返回主菜单
删除本文件
文件: /usr/lib/python3/dist-packages/twisted/internet/__pycache__/_producer_helpers.cpython-310.pyc
编辑文件内容
o �bE � @ sx U d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z ddl m Z g Z ee ed< ee�G d d � d ��Zd S ) z% Helpers for working with producers. � )�List)� implementer)� IPushProducer)� cooperate)�log)�safe_str�__all__c @ sL e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dS )� _PullToPusha� An adapter that converts a non-streaming to a streaming producer. Because of limitations of the producer API, this adapter requires the cooperation of the consumer. When the consumer's C{registerProducer} is called with a non-streaming producer, it must wrap it with L{_PullToPush} and then call C{startStreaming} on the resulting object. When the consumer's C{unregisterProducer} is called, it must call C{stopStreaming} on the L{_PullToPush} instance. If the underlying producer throws an exception from C{resumeProducing}, the producer will be unregistered from the consumer. @ivar _producer: the underling non-streaming producer. @ivar _consumer: the consumer with which the underlying producer was registered. @ivar _finished: C{bool} indicating whether the producer has finished. @ivar _coopTask: the result of calling L{cooperate}, the task driving the streaming producer. Fc C s || _ || _d S )N)� _producer� _consumer)�self� pullProducer�consumer� r �D/usr/lib/python3/dist-packages/twisted/internet/_producer_helpers.py�__init__2 s z_PullToPush.__init__c c s� � z| j �� W n7 ty@ t�ddt| j �f � z| j�� W n ty= t�ddt| j�f � d| _Y Y dS w Y nw dV q)z� A generator that calls C{resumeProducing} on the underlying producer forever. If C{resumeProducing} throws an exception, the producer is unregistered, which should result in streaming stopping. TNz%%s failed, producing will be stopped:z!%s failed to unregister producer:) r �resumeProducing� BaseExceptionr �errr r �unregisterProducer� _finished�r r r r �_pull6 s6 � �� ������z_PullToPush._pullc C s t | �� �| _dS )z� This should be called by the consumer when the producer is registered. Start streaming data to the consumer. N)r r � _coopTaskr r r r �startStreamingW s z_PullToPush.startStreamingc C s | j rdS d| _ | j�� dS )z� This should be called by the consumer when the producer is unregistered. Stop streaming data to the consumer. NT)r r �stopr r r r � stopStreaming_ s z_PullToPush.stopStreamingc C � | j �� dS )z7 @see: C{IPushProducer.pauseProducing} N)r �pauser r r r �pauseProducingk � z_PullToPush.pauseProducingc C r )z8 @see: C{IPushProducer.resumeProducing} N)r �resumer r r r r q r z_PullToPush.resumeProducingc C s | � � | j�� dS )z6 @see: C{IPushProducer.stopProducing} N)r r � stopProducingr r r r r" w s z_PullToPush.stopProducingN) �__name__� __module__� __qualname__�__doc__r r r r r r r r" r r r r r s ! r N)r& �typingr �zope.interfacer �twisted.internet.interfacesr �twisted.internet.taskr �twisted.pythonr �twisted.python.reflectr r �str�__annotations__r r r r r �<module> s
修改文件时间
将文件时间修改为当前时间的前一年
删除文件