֛hb%SrSSKJr SSKJr SSKJr SSKJr SSK J r \ "5r /r \\ \S'\"\5"SS 55rg ) z% Helpers for working with producers. )List) implementer) IPushProducer) cooperate)Logger__all__cF\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) _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. FcXlX lg)N) _producer _consumer)self pullProducerconsumers fC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/_producer_helpers.py__init___PullToPush.__init__3s %!c## [RSURS9nURR5 SSS5 WR(aZ[RSUR S9nUR R 5 SSS5 WR(aSUlgSv M!,(df  N=f!,(df  N>=f7f)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 resumeProducingfailedrunregisterProducer _finished)rop handlingops r_pull_PullToPush._pull7s%%=&..0yy))D!^^* NN557  $$&*DNJ! s3 CB67C4C'C6 CC CCc@[UR55Ulg)zo This should be called by the consumer when the producer is registered. Start streaming data to the consumer. N)rr _coopTaskrs rstartStreaming_PullToPush.startStreamingQs #4::<0rcjUR(agSUlURR5 g)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% >>  rc8URR5 g)z' @see: C{IPushProducer.pauseProducing} N)r#pauser$s rpauseProducing_PullToPush.pauseProducinges rc8URR5 g)z( @see: C{IPushProducer.resumeProducing} N)r#resumer$s rr_PullToPush.resumeProducingks rcXUR5 URR5 g)z& @see: C{IPushProducer.stopProducing} N)r)r stopProducingr$s rr3_PullToPush.stopProducingqs   $$&r)rr#rr N)__name__ __module__ __qualname____firstlineno____doc__rrr r%r)r-rr3__static_attributes__rrr r s10I"41   'rr N)r9typingrzope.interfacertwisted.internet.interfacesrtwisted.internet.taskrtwisted.loggerrrrstr__annotations__r r;rrrCsS &5+! xc ]^'^'^'r