final case class FlatMap[E, A, +E1 >: E, +B](io: MiniBIOAsync[E, A], f: (A) => MiniBIOAsync[E1, B]) extends MiniBIOAsync[E1, B] with Product with Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- FlatMap
- Serializable
- Product
- Equals
- MiniBIOAsync
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new FlatMap(io: MiniBIOAsync[E, A], f: (A) => MiniBIOAsync[E1, B])
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val f: (A) => MiniBIOAsync[E1, B]
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val io: MiniBIOAsync[E, A]
- 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()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def runOnEC(ec: ExecutionContext): Future[Uninterrupted[E1, B]]
Runs the effect on the provided ExecutionContext
Runs the effect on the provided ExecutionContext
- Definition Classes
- MiniBIOAsync
- Note
Even for synchronous effects, execution will be deferred to the EC.
- final def runSyncToFirstAsyncBoundary(): Either[Uninterrupted[E1, B], (ExecutionContext) => Future[Uninterrupted[E1, B]]]
Runs the effect synchronously until the first async boundary.
Runs the effect synchronously until the first async boundary.
- returns
Left if the effect completes synchronously, or Right with a continuation if async execution is needed.
- Definition Classes
- MiniBIOAsync
- final def runSyncToFirstAsyncBoundaryOrOnEC(ec: ExecutionContext): Future[Uninterrupted[E1, B]]
Runs the effect on current thread up to first async boundary and then migrates execution to provided ExecutionContext
Runs the effect on current thread up to first async boundary and then migrates execution to provided ExecutionContext
- returns
Completed future if there were no Async nodes, completable future otherwise
- Definition Classes
- MiniBIOAsync
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()