ActorPublisherTOnCompleteThenStop Method |
Complete the stream. After that you are not allowed to call OnNext(T), OnError(Exception) and OnComplete.
After signalling completion the Actor will then stop itself as it has completed the protocol. When OnComplete is called before any ISubscriber has had the chance to subscribe to this ActorPublisherT the completion signal (and therefore stopping of the Actor as well) will be delayed until such ISubscriber arrives.
Namespace: Akka.Streams.Actors