o bE@sxUdZddlmZddlmZddlmZddlmZddl m Z ddl m Z gZ eeed<eeGd d d Zd S) z% Helpers for working with producers. )List) implementer) IPushProducer) cooperate)log)safe_str__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)self pullProducerconsumerrD/usr/lib/python3/dist-packages/twisted/internet/_producer_helpers.py__init__2s z_PullToPush.__init__c cs z|jWn7ty@tddt|jfz|jWnty=tddt|jfd|_YYdSwYnwdVq)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 BaseExceptionrerrrr unregisterProducer _finishedr rrr_pull6s6    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 _coopTaskrrrrstartStreamingWsz_PullToPush.startStreamingcCs|jrdSd|_|jdS)z This should be called by the consumer when the producer is unregistered. Stop streaming data to the consumer. NT)rrstoprrrr stopStreaming_sz_PullToPush.stopStreamingcC|jdS)z7 @see: C{IPushProducer.pauseProducing} N)rpauserrrrpauseProducingkz_PullToPush.pauseProducingcCr)z8 @see: C{IPushProducer.resumeProducing} N)rresumerrrrrqr z_PullToPush.resumeProducingcCs||jdS)z6 @see: C{IPushProducer.stopProducing} N)rr stopProducingrrrrr"wsz_PullToPush.stopProducingN) __name__ __module__ __qualname____doc__rrrrrrrr"rrrrr s!  r N)r&typingrzope.interfacertwisted.internet.interfacesrtwisted.internet.taskrtwisted.pythonrtwisted.python.reflectrrstr__annotations__r rrrrs