tfbUdZddlmZddlmZddlmZddlmZddl m Z e Z gZ ee ed<eeGdd Zd S) z% Helpers for working with producers. )List) implementer) IPushProducer) cooperate)Logger__all__c@eZdZdZdZdZdZdZdZdZ dZ d Z d S) _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"||_||_dS)N) _producer _consumer)self pullProducerconsumers a/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/internet/_producer_helpers.py__init__z_PullToPush.__init__3s%!c#K td|j5}|jdddn #1swxYwY|jrbtd|j5}|jdddn #1swxYwY|jr d|_dSdV)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)rop handlingops r_pullz_PullToPush._pull7sU %%=& 1..000 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1y ))D!^*8 N55777 888888888888888 $&*DNFJJJ! s#A  AA>B$$B(+B(cRt||_dS)z This should be called by the consumer when the producer is registered. Start streaming data to the consumer. N)rr _coopTaskrs rstartStreamingz_PullToPush.startStreamingQs #4::<<00rcX|jrdSd|_|jdS)z This should be called by the consumer when the producer is unregistered. Stop streaming data to the consumer. NT)rr stopr!s r stopStreamingz_PullToPush.stopStreamingYs4 >  F rc8|jdS)z7 @see: C{IPushProducer.pauseProducing} N)r pauser!s rpauseProducingz_PullToPush.pauseProducinges rc8|jdS)z8 @see: C{IPushProducer.resumeProducing} N)r resumer!s rrz_PullToPush.resumeProducingks rc`||jdS)z6 @see: C{IPushProducer.stopProducing} N)r%r stopProducingr!s rr,z_PullToPush.stopProducingqs0  $$&&&&&rN) __name__ __module__ __qualname____doc__rrrr"r%r(rr,rrr r s0I"""4111       '''''rr N)r0typingrzope.interfacertwisted.internet.interfacesrtwisted.internet.taskrtwisted.loggerrrrstr__annotations__r r1rrr9s &&&&&&555555++++++!!!!!! vxxc ]^'^'^'^'^'^'^'^'^'^'r