U  W[^ã@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 ú5/usr/lib/python3/dist-packages/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)rZ transportZ writeSequencerrr r r r1szBufferingMixin.flush) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrr rrrr r r r rsrN)rZtwisted.internetrrr r r r Ús