File: //proc/self/root/usr/lib/python3/dist-packages/twisted/conch/__pycache__/mixin.cpython-38.pyc
U
W[^ � @ s" d Z ddlmZ G dd� 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< e Zd ZdZdZdZdZdd� Zdd� Zdd � Z d
d � Z
dS ) �BufferingMixinz+
Mixin which adds write buffering.
Ng c C s t �| j| j�S �N)r Z callLater�DELAY�flush��self� r �5/usr/lib/python3/dist-packages/twisted/conch/mixin.py�schedule s zBufferingMixin.schedulec C s |� | j� d S r )�resetr )r �tokenr r r
�
reschedule s zBufferingMixin.reschedulec C s8 | j dkr 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)�_delayedWriteCall�datar r �append)r r r r r
�write! s
zBufferingMixin.writec C s d| _ | j�| j� d| _dS )z/
Flush the buffer immediately.
N)r Z transportZ
writeSequencer r r r r
r 1 s zBufferingMixin.flush) �__name__�
__module__� __qualname__�__doc__r r r r r r r r r r r
r s r N)r Ztwisted.internetr r r r r r
�<module> s