diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-17 17:29:54 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-17 23:22:35 -0800 |
| commit | f1ad0247df5bf6e0315ffbb1633d5979da828de0 (patch) | |
| tree | ca96d1d960a13ae481b76fd32761ea535234f02b /kafka/protocol/commit.py | |
| parent | 799824535ceeb698152a3078f64ecbf6baca9b39 (diff) | |
| download | kafka-python-f1ad0247df5bf6e0315ffbb1633d5979da828de0.tar.gz | |
Switch BrokerConnection to (mostly) non-blocking IO.
- return kafka.Future on send()
- recv is now non-blocking call that completes futures when possible
- update KafkaClient to block on future completion
Diffstat (limited to 'kafka/protocol/commit.py')
0 files changed, 0 insertions, 0 deletions