o >hb@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)self pullProducerconsumerr/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/twisted/internet/_producer_helpers.py__init__3s z_PullToPush.__init__ccs tjd|jd }|jWdn1swY|jrGtjd|jd }|jWdn1s: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})producerNz.while calling unregisterProducer on {consumer})r )_logfailuresHandledr resumeProducingfailedr unregisterProducer _finished)r op handlingoprrr_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 rrrstartStreamingQsz_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 stopStreamingYsz_PullToPush.stopStreamingcC|jdS)z7 @see: C{IPushProducer.pauseProducing} N)rpauserrrrpauseProducingez_PullToPush.pauseProducingcCr )z8 @see: C{IPushProducer.resumeProducing} N)rresumerrrrrkr#z_PullToPush.resumeProducingcCs||jdS)z6 @see: C{IPushProducer.stopProducing} N)rr stopProducingrrrrr%qsz_PullToPush.stopProducingN) __name__ __module__ __qualname____doc__rrrrrr"rr%rrrrrs  rN)r)typingrzope.interfacertwisted.internet.interfacesrtwisted.internet.taskrtwisted.loggerrrrstr__annotations__rrrrrs