create a flow that is handled by an actor . messages can be sent downstream by sending them to the actor passed into the props function . this actor meets the contract of the actor returned by akka.stream.javadsl.source #actorref , defaulting to a buffer size of 16 , and failing the stream if the buffer gets full . the props function should return the props for an actor to handle the flow . this actor will be created using the passed in akka.actor.actorreffactory . each message received will be sent to the actor - there is no back pressure , if the actor is unable to process the messages , they will queue up in the actors mailbox . the upstream can be cancelled by the actor terminating itself . concode_field_sep PlaceHolder placeHolder concode_field_sep placeholderType placeHolder
Flow < In , Out , ? > function ( Function < ActorRef , Props > arg0 , ActorRefFactory arg1 , Materializer arg2 ) { return play . api . libs . streams . ActorFlow . < In , Out > actorRef ( new AbstractFunction1 < ActorRef , Props > ( ) { @ Override public Props apply ( ActorRef arg3 ) { return arg0 . apply ( arg3 ) ; } } , 16 , OverflowStrategy . fail ( ) , arg1 , arg2 ) . asJava ( ) ; }