We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Running code below;
var consumer = new Consumer(...); // initialize consumer Task.Factory.StartNew(() => { Console.WriteLine("Consumer started"); foreach (var m in bc.Consume()) Console.WriteLine(Encoding.UTF8.GetString(m.Value)); Console.WriteLine("Consumer finished"); }); // wait a sec; consumer.Dispose();
will never print Consumer finished even though consumer is in unusable state and bc.Consume() will never yield any result anymore.
Consumer finished
bc.Consume()
Is it possible to change behavior of Consumer on Dispose so it will release the thread that runs the .Consume() method?
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Running code below;
will never print
Consumer finished
even though consumer is in unusable state andbc.Consume()
will never yield any result anymore.Is it possible to change behavior of Consumer on Dispose so it will release the thread that runs the .Consume() method?
The text was updated successfully, but these errors were encountered: