Class ActorRefBackpressureSinkStage<In>

    • Constructor Detail

      • ActorRefBackpressureSinkStage

        public ActorRefBackpressureSinkStage​(ActorRef ref,
                                             scala.Function1<ActorRef,​scala.Function1<In,​java.lang.Object>> messageAdapter,
                                             scala.Function1<ActorRef,​java.lang.Object> onInitMessage,
                                             scala.Option<java.lang.Object> ackMessage,
                                             java.lang.Object onCompleteMessage,
                                             scala.Function1<java.lang.Throwable,​java.lang.Object> onFailureMessage)