o

�
b]�@s"dZd
dl
mZ
Gdd�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<eZ
dZd
ZdZdZdZdd�Zdd�Zdd	�Z	d
d�Z
dS)�BufferingMixinz+
    Mixin which adds write buffering.
    Ngc

Cst�
|j|j�S�
N)r�	callLater�DELAY�flush�
�self�r
�5/usr/lib/python3/dist-packages/twisted/conch/mixin.py�schedule�
zBufferingMixin.schedulecCs|
�|j
�

dSr)�resetr)r	�tokenr
r
r�
rescheduler
zBufferingMixin.reschedulecCs8|jd
urg|_
|��|_n|�|j�

|j
�|
�

d
S)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)r	rr
r
r�write!s




zBufferingMixin.writec

Csd
|_|j
�|j�

d
|_d
S)z/
        Flush the buffer immediately.
        N)r�	transport�
writeSequencerrr
r
rr0s


zBufferingMixin.flush)�__name__�
__module__�__qualname__�__doc__rrrrrrrr
r
r
rrs

rN)r�twisted.internetrrr
r
r
r�<module>
s