trait ActionBuilder[-I[_], +O[_], E, A] extends ActionFunction[I, O, E]
An ActionFunction from an input to an output. Used for creating actions.
- I
The input type of this builder.
- O
The action message type used by the command.
- A
The argument type of this command builder.
- Self Type
- ActionBuilder[I, O, E, A]
- Source
- actionBuilder.scala
- Alphabetic
- By Inheritance
- ActionBuilder
- ActionFunction
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- abstract type Action[B, Mat]
Abstract Value Members
- abstract def flow[A]: Flow[I[A], Either[Option[E], O[A]], NotUsed]
A flow that represents this mapping.
A flow that represents this mapping.
- Definition Classes
- ActionFunction
- abstract def requests: requests.Requests
A request helper that belongs to this builder.
- abstract def toSink[Mat](sinkBlock: Sink[O[A], Mat]): Action[A, Mat]
Creates an action from a sink.
Creates an action from a sink.
- Mat
The materialized result of running this action.
- sinkBlock
The sink that will process this action.
Concrete Value Members
- 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 andThen[O2[_]](that: ActionFunction[O, O2, E]): ActionFunction[I, O2, E]
Chains first this function, and then another one.
Chains first this function, and then another one.
- Definition Classes
- ActionFunction
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def async(block: (O[A]) => Future[Unit]): Action[A, NotUsed]
Creates an action that results in an async result
Creates an action that results in an async result
- block
The execution of the action.
- def asyncOpt(block: (O[A]) => OptFuture[Unit]): Action[A, NotUsed]
Creates an action that results in an partial async result
Creates an action that results in an partial async result
- block
The execution of the action.
- def asyncOptRequest[G[_]](block: (O[A]) => OptFuture[Request[Any]]): Action[A, NotUsed]
Creates an async action that might do a single request
Creates an async action that might do a single request
- G
The streamable result type.
- block
The execution of the action.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def streamed[G[_]](block: (O[A]) => G[Unit])(implicit streamable: util.Streamable[G]): Action[A, NotUsed]
Creates an action that results in some streamable type G
Creates an action that results in some streamable type G
- G
The streamable result type.
- block
The execution of the action.
- def streamedOptRequest[G[_]](block: (O[A]) => OptionT[G, Request[Any]])(implicit streamable: util.Streamable[G]): Action[A, NotUsed]
Creates an action that might do a single request, wrapped in an effect type G
Creates an action that might do a single request, wrapped in an effect type G
- G
The streamable result type.
- block
The execution of the action.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withRequest(block: (O[A]) => Request[Any]): Action[A, NotUsed]
Creates an action that will do a single request
Creates an action that will do a single request
- block
The execution of the action.
- def withRequestOpt(block: (O[A]) => Option[Request[Any]]): Action[A, NotUsed]
Creates an action that might do a single request
Creates an action that might do a single request
- block
The execution of the action.
- def withSideEffects(block: (O[A]) => Unit): Action[A, NotUsed]
Creates an action that might execute unknown side effects.
Creates an action that might execute unknown side effects.
- block
The execution of the action.