ActorRef[T]; sending messages to it will emit them on the stream. The source acknowledges reception after emitting a message, to provide back pressure from the source.
def actorRefWithAck[T, Ack](ackTo: ActorRef[Ack],ackMessage: Ack,completionMatcher: PartialFunction[T, CompletionStrategy],failureMatcher: PartialFunction[T, Throwable]): Source[T, ActorRef[T]]
ActorRef[T], sending messages to it will emit them on the stream. The actor responds with the provided ack message once the element could be emitted alowing for backpressure from the source. Sending another message before the previous one has been acknowledged will fail the stream.
emits when there is demand and there are messages in the buffer or a message is sent to the
completes when the
ActorRef is sent