+ DfjbaRt0tRt^RIHt^RIHt^RIHt^RIH t ^RI H t ] !4t .t ]^k]!]4!RR44tR #) z% Helpers for working with producers. )List) implementer) IPushProducer) cooperate)LoggercRa]tRt^toRtRtRtRtRtRt Rt Rt R t R t VtR #) _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. FcWnW nR#)N) _producer _consumer)self pullProducerconsumers&&&D/usr/lib/python3/dist-packages/twisted/internet/_producer_helpers.py__init___PullToPush.__init__3s %!c# "\PRVPR7;_uu_4pVPP4RRR4XP'dh\PRVP R7;_uu_4pVP P 4RRR4XP'd RVnR#RxK +'giL;i +'giLD;i5i)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 handlingops& r_pull_PullToPush._pull7s%%=&..0yyy))D!^^* NN557  $$$&*DNJ s@+C5CC5")C5 C"&C5C5 C C5" C2 -C5c B\VP44VnR#)zo This should be called by the consumer when the producer is registered. Start streaming data to the consumer. N)rr _coopTaskr s&rstartStreaming_PullToPush.startStreamingQs #4::<0rc pVP'dR#RVnVPP4R#)zp This should be called by the consumer when the producer is unregistered. Stop streaming data to the consumer. NT)rr stopr!s&r stopStreaming_PullToPush.stopStreamingYs' >>>  rc :VPP4R#)z' @see: C{IPushProducer.pauseProducing} N)r pauser!s&rpauseProducing_PullToPush.pauseProducinges rc :VPP4R#)z( @see: C{IPushProducer.resumeProducing} N)r resumer!s&rr_PullToPush.resumeProducingks rc ZVP4VPP4R#)z& @see: C{IPushProducer.stopProducing} N)r&r stopProducingr!s&rr0_PullToPush.stopProducingqs   $$&r)r r rr N)__name__ __module__ __qualname____firstlineno____doc__rrrr"r&r*rr0__static_attributes____classdictcell__) __classdict__s@rrrs90I"41   ''rrcVV^8dQh/^\9d\\,;R&#)__all__)__conditional_annotations__rstr)formats"r __annotate__r@s"crN)r=r6typingrzope.interfacertwisted.internet.interfacesrtwisted.internet.taskrtwisted.loggerrrr<rr@)r=s@rrFsN &5+! x ]^'^'^'r