Skip to content

The ability to stop consumers#76

Open
Antti wants to merge 1 commit intoAntti:masterfrom
pimeys:consumer_clean_exit
Open

The ability to stop consumers#76
Antti wants to merge 1 commit intoAntti:masterfrom
pimeys:consumer_clean_exit

Conversation

@Antti
Copy link
Owner

@Antti Antti commented Feb 28, 2019

No description provided.

@suvash
Copy link

suvash commented Nov 1, 2019

I was trying to implement clean exit for consumers (for eg. on receiving Ctrl+C), when I realised that it wasn't really possible right now externally, since channel.read() is blocking and there's no interface exposed to pass in a Arc<AtomicBool> as it seems like it's done in this PR.
This would definitely be a useful feature to have for production grade software.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants