class documentation
class _AggregateSmallWrites: (source)
Constructor: _AggregateSmallWrites(write, clock)
Aggregate small writes so they get written in large batches.
If this is used as part of a transport, the transport needs to call ``flush()`` immediately when ``loseConnection()`` is called, otherwise any buffered writes will never get written.
Method | __init__ |
Undocumented |
Method | flush |
Flush any buffered writes. |
Method | write |
Buffer the data, or write it immediately if we've accumulated enough to make it worth it. |
Constant | MAX |
The maximum amount of bytes to buffer before writing them out. |
Method | _scheduled |
Called in next reactor iteration. |
Instance Variable | _buffer |
Undocumented |
Instance Variable | _buffer |
Undocumented |
Instance Variable | _clock |
Undocumented |
Instance Variable | _scheduled |
Undocumented |
Instance Variable | _write |
Undocumented |