summary refs log tree commit diff
path: root/synapse/util/file_consumer.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Do logcontexts correctlyErik Johnston2018-01-181-2/+2
|
* Move test stuff to testsErik Johnston2018-01-181-25/+1
|
* Make all fields privateErik Johnston2018-01-181-31/+31
|
* Ensure we registerProducer isn't called twiceErik Johnston2018-01-181-0/+3
|
* Fix _notify_empty typoErik Johnston2018-01-181-1/+1
|
* Move definition of paused_producer to __init__Erik Johnston2018-01-181-2/+4
|
* Fix commentsErik Johnston2018-01-181-3/+3
|
* Add decent impl of a FileConsumerErik Johnston2018-01-171-0/+158
Twisted core doesn't have a general purpose one, so we need to write one ourselves. Features: - All writing happens in background thread - Supports both push and pull producers - Push producers get paused if the consumer falls behind