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
- 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
- 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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- 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 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 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
- final def getClass(): Class[_ <: AnyRef]
- 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 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
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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
- 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: (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