\d]0dZddlmZGddZdS)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 )reactorc6eZdZdZdZdZdZdZdZdZ dZ dS)BufferingMixinz+ Mixin which adds write buffering. Ngc@tj|j|jSN)r callLaterDELAYflushselfs 3lib/python3.11/site-packages/twisted/conch/mixin.pyschedulezBufferingMixin.schedules TZ888c:||jdSr)resetr )r tokens r reschedulezBufferingMixin.reschedules DJrc|j!g|_||_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)_delayedWriteCalldatarrappend)r rs r writezBufferingMixin.write!sX  ! )DI%)]]__D " " OOD2 3 3 3 rc`d|_|j|jd|_dS)z/ Flush the buffer immediately. N)r transport writeSequencerr s r r zBufferingMixin.flush0s/"& $$TY/// r) __name__ __module__ __qualname____doc__rrr rrrr rr rrsl D E999      rrN)rtwisted.internetrrr rr r"sU %$$$$$%%%%%%%%%%r