Showing content from https://www.playframework.com/documentation/2.5.x/api/scala/play/api/libs/streams/ActorFlow$.html below:
ActorFlow - play.api.libs.streams.ActorFlow
final def !=(arg0: Any): Boolean
-
Definition Classes
-
AnyRef â Any
final def ##(): Int
-
Definition Classes
-
AnyRef â Any
final def ==(arg0: Any): Boolean
-
Definition Classes
-
AnyRef â Any
def actorRef[In, Out](props: (ActorRef) â Props, bufferSize: Int = 16, overflowStrategy: OverflowStrategy = OverflowStrategy.dropNew)(implicit factory: ActorRefFactory, mat: Materializer): Flow[In, Out, _]
Create a flow that is handled by an actor.
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.scaladsl.Source.actorRef.
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.
-
props
-
A function that creates the props for actor to handle the flow.
-
bufferSize
-
The maximum number of elements to buffer.
-
overflowStrategy
-
The strategy for how to handle a buffer overflow.
final def asInstanceOf[T0]: T0
-
Definition Classes
-
Any
def clone(): AnyRef
-
Attributes
-
protected[java.lang]
-
Definition Classes
-
AnyRef
-
Annotations
-
@throws( ... )
final def eq(arg0: AnyRef): Boolean
-
Definition Classes
-
AnyRef
def equals(arg0: Any): Boolean
-
Definition Classes
-
AnyRef â Any
def finalize(): Unit
-
Attributes
-
protected[java.lang]
-
Definition Classes
-
AnyRef
-
Annotations
-
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]
-
Definition Classes
-
AnyRef â Any
def hashCode(): Int
-
Definition Classes
-
AnyRef â Any
final def isInstanceOf[T0]: Boolean
-
Definition Classes
-
Any
final def ne(arg0: AnyRef): Boolean
-
Definition Classes
-
AnyRef
final def notify(): Unit
-
Definition Classes
-
AnyRef
final def notifyAll(): Unit
-
Definition Classes
-
AnyRef
final def synchronized[T0](arg0: â T0): T0
-
Definition Classes
-
AnyRef
def toString(): String
-
Definition Classes
-
AnyRef â Any
final def wait(): Unit
-
Definition Classes
-
AnyRef
-
Annotations
-
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit
-
Definition Classes
-
AnyRef
-
Annotations
-
@throws( ... )
final def wait(arg0: Long): Unit
-
Definition Classes
-
AnyRef
-
Annotations
-
@throws( ... )
RetroSearch is an open source project built by @garambo
| Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4