These are chat archives for akkadotnet/AkkaStreams
assertAllStagesStoppedinside all tests. Why we need it, and how I could use in on .NET?
asyncCallback = GetAsyncCallback<MyEvent>(yourHandlingLogic)and then invoke that action inside event handler like
event += (sender, args) => asyncCallback(AsMyEvent(sender, args)). Async callbacks are used as wrappers around your logic, so that you action is not invoked immediately, but the invocation point is being managed by akka materializer instead. Think of it like GetAsyncCallback takes a message handler as a parameter and return a mailbox/actorRef Send method.
Confluent.Kafkanightly version has