o زَ·ibم@srUdZddlmZddlmZddlmZddlmZddl m Z e ƒZgZee ed<eeƒGdd „d ƒƒZd S)z% Helpers for working with producers. é)عList)عimplementer)ع IPushProducer)ع cooperate)عLoggerع__all__c@sLeZdZdZdZdd„Zdd„Zdd„Zd d „Zdd„Z d d„Z dd„ZdS)ع_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. FcCs||_||_dS)N)ع _producerع _consumer)عselfZpullProducerعconsumer©r ْhC:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\twisted/internet/_producer_helpers.pyع__init__3s z_PullToPush.__init__ccs–پ tjd|jdچڈ }|j ،Wdƒn1swY|jrGtjd|jdچڈ }|j ،Wdƒn1s:wY|jrGd|_dSdVq)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. Tz+while calling resumeProducing on {producer})ZproducerNz.while calling unregisterProducer on {consumer})r)ع_logZfailuresHandledr عresumeProducingعfailedr ZunregisterProducerع _finished)rعopZ handlingopr r rع_pull7s*€ے‎‏üًz_PullToPush._pullcCst| ،ƒ|_dS)z‡ This should be called by the consumer when the producer is registered. Start streaming data to the consumer. N)rrع _coopTask©rr r rعstartStreamingQsz_PullToPush.startStreamingcCs|jrdSd|_|j ،dS)zگ This should be called by the consumer when the producer is unregistered. Stop streaming data to the consumer. NT)rrعstoprr r rع stopStreamingYsz_PullToPush.stopStreamingcCَ|j ،dS)z7 @see: C{IPushProducer.pauseProducing} N)rZpauserr r rعpauseProducingeَz_PullToPush.pauseProducingcCr)z8 @see: C{IPushProducer.resumeProducing} N)rعresumerr r rrkrz_PullToPush.resumeProducingcCs| ،|j ،dS)z6 @see: C{IPushProducer.stopProducing} N)rr ع stopProducingrr r rrqsz_PullToPush.stopProducingN)ع__name__ع __module__ع__qualname__ع__doc__rrrrrrrrr r r rrsrN)r#عtypingrZzope.interfacerZtwisted.internet.interfacesrZtwisted.internet.taskrZtwisted.loggerrrrعstrع__annotations__rr r r rعs