These are chat archives for akkadotnet/AkkaStreams
public static Sink<TIn, NotUsed> ActorRef<TIn>(IActorRef actorRef, object onCompleteMessage, IActorRef receiverActorRef) => new Sink<TIn, NotUsed>(new ActorRefSink<TIn>(actorRef, onCompleteMessage, receiverActorRef, DefaultAttributes.ActorRefSink, Shape<TIn>("ActorRefSink")));
QueueOfferResult.Failure- it's opt in and used only if your overflow strategy is Fail.
Receive<ByteString>. Then I'm not sure how the flow control is going to work in this case. I assumed that if I create those special stream actors (one from source at sender's side and one from source at receiver side), they will interact with each other and the magic will handle the flow control events during data exchange. Then the completion messages will be sent to parent ReceiveActor. Something like in the scheme below (again, I'm might be misinterpreting things :)):