/usr/lib/python3/dist-packages/twisted/conch/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/conch/__pycache__/mixin.cpython-310.pyc (1700B)
o
¯b] ã @ 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 Ú callLaterÚDELAYÚflush©Úself© r
ú5/usr/lib/python3/dist-packages/twisted/conch/mixin.pyÚschedule ó zBufferingMixin.schedulec C s | | j¡ d S r )Úresetr )r Útokenr
r
r Ú
reschedule r
zBufferingMixin.reschedulec C s8 | j du rg | _| ¡ | _ 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 Ú transportÚ
writeSequencer r r
r
r r 0 s
zBufferingMixin.flush) Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r r r r r r r
r
r
r r s r N)r Útwisted.internetr r r
r
r
r Ú
s