object ZChannel
- Alphabetic
- By Inheritance
- ZChannel
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- final class EnvironmentWithChannelPartiallyApplied[Env] extends AnyVal
- final class EnvironmentWithPartiallyApplied[Env] extends AnyVal
- final class EnvironmentWithZIOPartiallyApplied[Env] extends AnyVal
- sealed abstract class MergeDecision[-R, -E0, -Z0, +E, +Z] extends AnyRef
- sealed trait MergeStrategy extends AnyRef
- final class ProvideSomeLayer[Env0, -Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone] extends AnyVal
- final class ScopedPartiallyApplied[R] extends AnyVal
- final class ServiceAtPartiallyApplied[Service] extends AnyVal
- final class ServiceWithChannelPartiallyApplied[Service] extends AnyVal
- final class ServiceWithPartiallyApplied[Service] extends AnyVal
- final class ServiceWithZIOPartiallyApplied[Service] extends AnyVal
- final class UnwrapScopedPartiallyApplied[Env] extends AnyVal
- final class UpdateService[-Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone, Service] extends AnyVal
- final class UpdateServiceAt[-Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone, Service] extends AnyVal
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 acquireReleaseExitWith[Env, InErr, InElem, InDone, OutErr, Acquired, OutElem2, OutDone](acquire: ⇒ ZIO[Env, OutErr, Acquired])(release: (Acquired, Exit[OutErr, OutDone]) ⇒ URIO[Env, Any])(use: (Acquired) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem2, OutDone])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem2, OutDone]
- def acquireReleaseOutExitWith[Env, OutErr, Acquired](acquire: ⇒ ZIO[Env, OutErr, Acquired])(release: (Acquired, Exit[Any, Any]) ⇒ URIO[Env, Any])(implicit trace: Trace): ZChannel[Env, Any, Any, Any, OutErr, Acquired, Unit]
- def acquireReleaseOutWith[Env, OutErr, Acquired](acquire: ⇒ ZIO[Env, OutErr, Acquired])(release: (Acquired) ⇒ URIO[Env, Any])(implicit trace: Trace): ZChannel[Env, Any, Any, Any, OutErr, Acquired, Unit]
- def acquireReleaseWith[Env, InErr, InElem, InDone, OutErr, Acquired, OutElem2, OutDone](acquire: ⇒ ZIO[Env, OutErr, Acquired])(release: (Acquired) ⇒ URIO[Env, Any])(use: (Acquired) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem2, OutDone])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem2, OutDone]
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
buffer[InErr, InElem, InDone](empty: ⇒ InElem, isEmpty: (InElem) ⇒ Boolean, ref: ⇒ Ref[InElem])(implicit trace: Trace): ZChannel[Any, InErr, InElem, InDone, InErr, InElem, InDone]
Creates a channel backed by a buffer.
Creates a channel backed by a buffer. When the buffer is empty, the channel will simply passthrough its input as output. However, when the buffer is non-empty, the value inside the buffer will be passed along as output.
- def bufferChunk[InErr, InElem, InDone](ref: ⇒ Ref[Chunk[InElem]])(implicit trace: Trace): ZChannel[Any, InErr, Chunk[InElem], InDone, InErr, Chunk[InElem], InDone]
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def concatAll[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](channels: ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, Any], Any])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, Any]
- def concatAllWith[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone, OutDone2, OutDone3](channels: ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone], OutDone2])(f: (OutDone, OutDone) ⇒ OutDone, g: (OutDone, OutDone2) ⇒ OutDone3)(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone3]
-
def
environment[Env](implicit trace: Trace): ZChannel[Env, Any, Any, Any, Nothing, Nothing, ZEnvironment[Env]]
Accesses the whole environment of the channel.
-
def
environmentWith[Env]: EnvironmentWithPartiallyApplied[Env]
Accesses the environment of the channel.
-
def
environmentWithChannel[Env]: EnvironmentWithChannelPartiallyApplied[Env]
Accesses the environment of the channel in the context of a channel.
-
def
environmentWithZIO[Env]: EnvironmentWithZIOPartiallyApplied[Env]
Accesses the environment of the channel in the context of an effect.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def fail[E](e: ⇒ E)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]
- def failCause[E](cause: ⇒ Cause[E])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def fromEither[E, A](either: ⇒ Either[E, A])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, A]
- def fromHub[Err, Done, Elem](hub: ⇒ Hub[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Err, Elem, Done]
- def fromHubScoped[Err, Done, Elem](hub: ⇒ Hub[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZIO[Scope, Nothing, ZChannel[Any, Any, Any, Any, Err, Elem, Done]]
- def fromOption[A](option: ⇒ Option[A])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, None.type, Nothing, A]
- def fromQueue[Err, Done, Elem](queue: ⇒ Dequeue[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Err, Elem, Done]
- def fromZIO[R, E, A](zio: ⇒ ZIO[R, E, A])(implicit trace: Trace): ZChannel[R, Any, Any, Any, E, Nothing, A]
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def identity[Err, Elem, Done](implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Err, Elem, Done]
- def interruptAs(fiberId: ⇒ FiberId)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Nothing]
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def mergeAll[Env, InErr, InElem, InDone, OutErr, OutElem](channels: ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, Any], Any], n: ⇒ Int, bufferSize: ⇒ Int = 16, mergeStrategy: ⇒ MergeStrategy = MergeStrategy.BackPressure)(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, Any]
- def mergeAllUnbounded[Env, InErr, InElem, InDone, OutErr, OutElem](channels: ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, Any], Any])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, Any]
- def mergeAllUnboundedWith[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](channels: ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone], OutDone])(f: (OutDone, OutDone) ⇒ OutDone)(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
- def mergeAllWith[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](channels: ZChannel[Env, InErr, InElem, InDone, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone], OutDone], n: ⇒ Int, bufferSize: ⇒ Int = 16, mergeStrategy: ⇒ MergeStrategy = MergeStrategy.BackPressure)(f: (OutDone, OutDone) ⇒ OutDone)(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
never(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Nothing]
Returns a channel that never completes
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def provideLayer[Env0, Env, Env1, InErr, InElem, InDone, OutErr, OutElem, OutDone](layer: ZLayer[Env0, OutErr, Env])(channel: ⇒ ZChannel[Env with Env1, InErr, InElem, InDone, OutErr, OutElem, OutDone])(implicit ev: zio.EnvironmentTag[Env], tag: zio.EnvironmentTag[Env1], trace: Trace): ZChannel[Env0 with Env1, InErr, InElem, InDone, OutErr, OutElem, OutDone]
- def read[In](implicit trace: Trace): ZChannel[Any, Any, In, Any, None.type, Nothing, In]
- def readOrFail[E, In](e: ⇒ E)(implicit trace: Trace): ZChannel[Any, Any, In, Any, E, Nothing, In]
- def readWith[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](in: (InElem) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone], error: (InErr) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone], done: (InDone) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
- def readWithCause[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](in: (InElem) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone], halt: (Cause[InErr]) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone], done: (InDone) ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
- def refailCause[E](cause: Cause[E]): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]
- def scoped[R]: ScopedPartiallyApplied[R]
-
def
service[Service](implicit arg0: Tag[Service], trace: Trace): ZChannel[Service, Any, Any, Any, Nothing, Nothing, Service]
Accesses the specified service in the environment of the channel.
-
def
serviceAt[Service]: ServiceAtPartiallyApplied[Service]
Accesses the service corresponding to the specified key in the environment.
-
def
serviceWith[Service]: ServiceWithPartiallyApplied[Service]
Accesses the specified service in the environment of the channel.
-
def
serviceWithChannel[Service]: ServiceWithChannelPartiallyApplied[Service]
Accesses the specified service in the environment of the channel in the context of a channel.
-
def
serviceWithZIO[Service]: ServiceWithZIOPartiallyApplied[Service]
Accesses the specified service in the environment of the channel in the context of an effect.
-
def
succeed[Z](z: ⇒ Z)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Z]
Creates a channel that succeeds immediately with the given value
- def succeedNow[Z](result: Z)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Z]
- def succeedWith[R, Z](f: (ZEnvironment[R]) ⇒ Z)(implicit trace: Trace): ZChannel[R, Any, Any, Any, Nothing, Nothing, Z]
-
def
suspend[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](channel: ⇒ ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
Returns a lazily constructed channel.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- def toHub[Err, Done, Elem](hub: ⇒ Hub[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Nothing, Nothing, Any]
- def toQueue[Err, Done, Elem](queue: ⇒ Enqueue[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Nothing, Nothing, Any]
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
val
unit: ZChannel[Any, Any, Any, Any, Nothing, Nothing, Unit]
Channel that succeeds with the unit value
- def unwrap[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](channel: ⇒ ZIO[Env, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
- def unwrapScoped[Env]: UnwrapScopedPartiallyApplied[Env]
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def write[Out](out: Out)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]
- def writeAll[Out](outs: Out*)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]
- def writeChunk[Out](outs: Chunk[Out])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]
- object MergeDecision
- object MergeStrategy