Python client library : stoping a stream consumer



I’m looking a the Python client library version 2. I can’t figure out how to stop consuming a stream. Am I supposed to use some low level function form the multiprocessing library or is there a mean that I’ve missed ?




You can currently do this by doing this:

client.start_stream_subscriber() time.sleep(10) client._stream_process.terminate()

I agree that it’s not easy to do, and I will add extra process control functions to the next release.


Thanks. Putting those three lines in the example in the documentation would be very helpful.