ojEUdZddlmZddlmZddlmZddlmZddl m Z ddl m Z gZ eeed<eeGd d Zy ) z% Helpers for working with producers. )List) implementer) IPushProducer) cooperate)log)safe_str__all__c>eZdZdZdZdZdZdZdZdZ dZ d Z y ) _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 ||_||_y)N) _producer _consumer)self pullProducerconsumers D/usr/lib/python3/dist-packages/twisted/internet/_producer_helpers.py__init__z_PullToPush.__init__2s%!c#K |jjd #t$rtjdt |jd |j jnC#t$r7tjdt |j dd|_YYywxYwYwxYww)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# failed, producing will be stopped:z failed to unregister producer:) r resumeProducing BaseExceptionrerrrrunregisterProducer _finishedrs r_pullz_PullToPush._pull6s ..0*J/! /2 NN557% GG#DNN36 &*DN 8 sOB>$B>5B;A54B;54B55B;8B>:B;;B>c@t|j|_y)z This should be called by the consumer when the producer is registered. Start streaming data to the consumer. N)rr _coopTaskrs rstartStreamingz_PullToPush.startStreamingWs #4::<0rc`|jryd|_|jjy)z This should be called by the consumer when the producer is unregistered. Stop streaming data to the consumer. NT)rrstoprs r stopStreamingz_PullToPush.stopStreaming_s% >>  rc8|jjy)z7 @see: C{IPushProducer.pauseProducing} N)rpausers rpauseProducingz_PullToPush.pauseProducingks rc8|jjy)z8 @see: C{IPushProducer.resumeProducing} N)rresumers rrz_PullToPush.resumeProducingqs rcX|j|jjy)z6 @see: C{IPushProducer.stopProducing} N)r"r stopProducingrs rr)z_PullToPush.stopProducingws   $$&rN) __name__ __module__ __qualname____doc__rrrrr"r%rr)rrr r s20I"B1   'rr N)r-typingrzope.interfacertwisted.internet.interfacesrtwisted.internet.taskrtwisted.pythonrtwisted.python.reflectrr str__annotations__r r.rrr7sO &5++c ]e'e'e'r