object pure
- Source
- pure.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- pure
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- final case class FiberCtx[E](self: PureFiber[E, _], masks: List[MaskId] = Nil, finalizers: List[PureConc[E, Unit]] = Nil) extends Product with Serializable
- type FiberR[E, A] = Kleisli[[β$0$]Outcome[[A]A, E, β$0$], FiberCtx[E], A]
- type Finalizer[E] = Kleisli[[β$2$]FreeT[ThreadF, [β$1$]Kleisli[[β$0$]Outcome[[A]A, E, β$0$], FiberCtx[E], β$1$], β$2$], Universe, Unit]
- type IdOC[E, A] = Outcome[Id, E, A]
- type MVarR[F[_], A] = Kleisli[F, Universe, A]
- final class MaskId extends AnyRef
- type PureConc[E, A] = Kleisli[[β$2$]FreeT[ThreadF, [β$1$]Kleisli[[β$0$]Outcome[[A]A, E, β$0$], FiberCtx[E], β$1$], β$2$], Universe, A]
- final class PureFiber[E, A] extends Fiber[[β$60$]Kleisli[[β$2$]FreeT[ThreadF, [β$1$]Kleisli[[β$0$]Outcome[[A]A, E, β$0$], FiberCtx[E], β$1$], β$2$], UnsafeRef[Map[MVar[Any], Any]], β$60$], E, A] with Serializable
- type ResolvedPC[E, A] = FreeT[ThreadF, [β$3$]Outcome[[A]A, E, β$3$], A]
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
- implicit def allocateForPureConc[E]: GenConcurrent[[β$23$]Kleisli[[β$2$]FreeT[ThreadF, [β$1$]Kleisli[[β$0$]Outcome[[A]A, E, β$0$], FiberCtx[E], β$1$], β$2$], UnsafeRef[Map[MVar[Any], Any]], β$23$], E]
- 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
- implicit def eqPureConc[E, A](implicit arg0: Eq[E], arg1: Eq[A]): Eq[PureConc[E, A]]
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit def monadErrorIdOC[E]: MonadError[[β$4$]Outcome[[A]A, E, β$4$], E]
- 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()
- implicit def orderForPureConc[E, A](implicit arg0: Order[E], arg1: Order[A]): Order[PureConc[E, A]]
- def resolveMain[E, A](pc: PureConc[E, A]): ResolvedPC[E, IdOC[E, A]]
- def run[E, A](pc: PureConc[E, A]): Outcome[Option, E, A]
Produces Succeeded(None) when the main fiber is deadlocked.
Produces Succeeded(None) when the main fiber is deadlocked. Note that deadlocks outside of the main fiber are ignored when results are appropriately produced (i.e. daemon semantics).
- implicit def showPureConc[E, A](implicit arg0: Show[E], arg1: Show[A]): Show[PureConc[E, A]]
- 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(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()
- object MaskId