summary refs log tree commit diff
path: root/synapse/util/file_consumer.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Update black, and run auto formatting over the codebase (#9381)Eric Eastwood2021-02-161-10/+5
| | | | | | | - Update black version to the latest - Run black auto formatting over the codebase - Run autoformatting according to [`docs/code_style.md `](https://github.com/matrix-org/synapse/blob/80d6dc9783aa80886a133756028984dbf8920168/docs/code_style.md) - Update `code_style.md` docs around installing black to use the correct version
* Stop sub-classing object (#8249)Patrick Cloke2020-09-041-1/+1
|
* Replace all remaining six usage with native Python 3 equivalents (#7704)Dagfinn Ilmari Mannsåker2020-06-161-1/+1
|
* Move logging utilities out of the side drawer of util/ and into logging/ (#5606)Amber Brown2019-07-041-1/+1
|
* run isortAmber Brown2018-07-091-2/+2
|
* Pass around the reactor explicitly (#3385)Amber Brown2018-06-221-5/+11
|
* Use run_in_background in preference to preserve_fnRichard van der Hoff2018-04-271-2/+4
| | | | | | While I was going through uses of preserve_fn for other PRs, I converted places which only use the wrapped function once to use run_in_background, to avoid creating the function object.
* Replace Queue with six.moves.queueAdrian Tschira2018-04-161-2/+2
| | | | | | and a six.range change which I missed the last time Signed-off-by: Adrian Tschira <nota@notafile.com>
* 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