case class EventListenerBuilder[+M[_], A <: APIMessage](requests: Requests, refineEvent: (APIMessage) => Option[A], actionFunction: ActionFunction[EventListenerMessage, M, Nothing]) extends ActionBuilder[EventListenerMessage, M, Nothing, A] with Product with Serializable
- Self Type
- EventListenerBuilder[M, A]
- Source
- eventListenerBuilder.scala
- Alphabetic
- By Inheritance
- EventListenerBuilder
- Serializable
- Product
- Equals
- ActionBuilder
- ActionFunction
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new EventListenerBuilder(requests: Requests, refineEvent: (APIMessage) => Option[A], actionFunction: ActionFunction[EventListenerMessage, M, Nothing])
Type Members
- type Action[B, Mat] = EventListener[B, Mat]
- Definition Classes
- EventListenerBuilder → ActionBuilder
Value Members
- val actionFunction: ActionFunction[EventListenerMessage, M, Nothing]
- def andThen[O2[_]](that: ActionFunction[M, O2, Nothing]): EventListenerBuilder[O2, A]
Chains first this function, and then another one.
Chains first this function, and then another one.
- Definition Classes
- EventListenerBuilder → ActionFunction
- def async(block: (M[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.
- Definition Classes
- ActionBuilder
- def asyncOpt(block: (M[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.
- Definition Classes
- ActionBuilder
- def asyncOptRequest[G[_]](block: (M[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.
- Definition Classes
- ActionBuilder
- def flow[C]: Flow[EventListenerMessage[C], Either[Option[Nothing], M[C]], NotUsed]
A flow that represents this mapping.
A flow that represents this mapping.
- Definition Classes
- EventListenerBuilder → ActionFunction
- def on[B <: A](implicit tag: ClassTag[B]): EventListenerBuilder[M, B]
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val refineEvent: (APIMessage) => Option[A]
- val requests: Requests
A request helper that belongs to this builder.
A request helper that belongs to this builder.
- Definition Classes
- EventListenerBuilder → ActionBuilder
- def streamed[G[_]](block: (M[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.
- Definition Classes
- ActionBuilder
- def streamedOptRequest[G[_]](block: (M[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.
- Definition Classes
- ActionBuilder
- def toSink[Mat](sinkBlock: Sink[M[A], Mat]): EventListener[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.
- Definition Classes
- EventListenerBuilder → ActionBuilder
- def withRequest(block: (M[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.
- Definition Classes
- ActionBuilder
- def withRequestOpt(block: (M[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.
- Definition Classes
- ActionBuilder
- def withSideEffects(block: (M[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.
- Definition Classes
- ActionBuilder