U Acj]ć@s"dZddlmZGdd„dƒZdS)z° Experimental optimization This module provides a single mixin class which allows protocols to collapse numerous small writes into a single larger one. @author: Jp Calderone é)Śreactorc@s<eZdZdZdZdZdZdd„Zdd„Zdd „Z d d „Z dS) ŚBufferingMixinz+ Mixin which adds write buffering. NgcCst |j|j”S©N)rZ callLaterŚDELAYŚflush©Śself©r ś7/tmp/pip-unpacked-wheel-nrvc_22y/twisted/conch/mixin.pyŚscheduleszBufferingMixin.schedulecCs| |j”dSr)Śresetr)rŚtokenr r r Ś rescheduleszBufferingMixin.reschedulecCs8|jdkrg|_| ”|_n | |j”|j |”dS)a Buffer some bytes to be written soon. Every call to this function delays the real write by C{self.DELAY} seconds. When the delay expires, all collected bytes are written to the underlying transport using L{ITransport.writeSequence}. N)Ś_delayedWriteCallŚdatar rŚappend)rrr r r Śwrite!s    zBufferingMixin.writecCsd|_|j |j”d|_dS)z/ Flush the buffer immediately. N)rŚ transportZ writeSequencerrr r r r0szBufferingMixin.flush) Ś__name__Ś __module__Ś __qualname__Ś__doc__rrrr rrrr r r r rsrN)rZtwisted.internetrrr r r r Śs