Python client library : stoping a stream consumer


#1

Hi,

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 ?

Thanks,

Jean-Philippe


#2

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.


#3

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