U Tgb@srUdZddlmZddlmZddlmZddlmZddl m Z e Z gZ ee ed<eeGdd d Zd S) z% Helpers for working with producers. )List) implementer) IPushProducer) cooperate)Logger__all__c@sLeZdZdZdZddZddZddZd d Zd d Z d dZ ddZ 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. FcCs||_||_dS)N) _producer _consumer)selfZ pullProducerconsumerr F/tmp/pip-unpacked-wheel-1_7di8ic/twisted/internet/_producer_helpers.py__init__3sz_PullToPush.__init__c csntjd|jd}|jW5QRX|jrbtjd|jd}|jW5QRX|jrbd|_dSdVqdS)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. z+while calling resumeProducing on {producer})Zproducerz.while calling unregisterProducer on {consumer})r TN)_logZfailuresHandledr resumeProducingfailedr 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 _coopTaskr r r rstartStreamingQsz_PullToPush.startStreamingcCs|jr dSd|_|jdS)z This should be called by the consumer when the producer is unregistered. Stop streaming data to the consumer. NT)rrstoprr r r stopStreamingYsz_PullToPush.stopStreamingcCs|jdS)z7 @see: C{IPushProducer.pauseProducing} N)rpauserr r rpauseProducingesz_PullToPush.pauseProducingcCs|jdS)z8 @see: C{IPushProducer.resumeProducing} N)rresumerr r rrksz_PullToPush.resumeProducingcCs||jdS)z6 @see: C{IPushProducer.stopProducing} N)rr stopProducingrr r rrqsz_PullToPush.stopProducingN) __name__ __module__ __qualname____doc__rrrrrrrrr r r rrs rN)r"typingrZzope.interfacerZtwisted.internet.interfacesrZtwisted.internet.taskrZtwisted.loggerrrrstr__annotations__rr r r rs