Add a context to sniffers and subscribers, so that cancelling a subscriber or sniffer directly can use a context provided by user or internally to manage shutdown timeouts and drainage. Might need a const somewhere to more optimally configure timeouts, since it's hardcoded right now. A configuration block to the sniffer init maybe?
Add a context to sniffers and subscribers, so that cancelling a subscriber or sniffer directly can use a context provided by user or internally to manage shutdown timeouts and drainage. Might need a const somewhere to more optimally configure timeouts, since it's hardcoded right now. A configuration block to the sniffer init maybe?