Packages

object ZChannel

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZChannel
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final class EnvironmentWithChannelPartiallyApplied[Env] extends AnyVal
  2. final class EnvironmentWithPartiallyApplied[Env] extends AnyVal
  3. final class EnvironmentWithZIOPartiallyApplied[Env] extends AnyVal
  4. sealed abstract class MergeDecision[-R, -E0, -Z0, +E, +Z] extends AnyRef
  5. sealed trait MergeStrategy extends AnyRef
  6. final class ProvideSomeLayer[Env0, -Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone] extends AnyVal
  7. final class ScopedPartiallyApplied[R] extends AnyVal
  8. final class ServiceAtPartiallyApplied[Service] extends AnyVal
  9. final class ServiceWithChannelPartiallyApplied[Service] extends AnyVal
  10. final class ServiceWithPartiallyApplied[Service] extends AnyVal
  11. final class ServiceWithZIOPartiallyApplied[Service] extends AnyVal
  12. final class UnwrapScopedPartiallyApplied[Env] extends AnyVal
  13. final class UpdateService[-Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone, Service] extends AnyVal
  14. final class UpdateServiceAt[-Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone, Service] extends AnyVal

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. 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]
  5. 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]
  6. 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]
  7. 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]
  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. 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.

  10. def bufferChunk[InErr, InElem, InDone](ref: => Ref[Chunk[InElem]])(implicit trace: Trace): ZChannel[Any, InErr, Chunk[InElem], InDone, InErr, Chunk[InElem], InDone]
  11. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  12. 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]
  13. 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]
  14. def environment[Env](implicit trace: Trace): ZChannel[Env, Any, Any, Any, Nothing, Nothing, ZEnvironment[Env]]

    Accesses the whole environment of the channel.

  15. def environmentWith[Env]: EnvironmentWithPartiallyApplied[Env]

    Accesses the environment of the channel.

  16. def environmentWithChannel[Env]: EnvironmentWithChannelPartiallyApplied[Env]

    Accesses the environment of the channel in the context of a channel.

  17. def environmentWithZIO[Env]: EnvironmentWithZIOPartiallyApplied[Env]

    Accesses the environment of the channel in the context of an effect.

  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  20. def fail[E](e: => E)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]
  21. def failCause[E](cause: => Cause[E])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]
  22. def fromEither[E, A](either: => Either[E, A])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, A]
  23. def fromHub[Err, Done, Elem](hub: => Hub[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Err, Elem, Done]
  24. 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]]
  25. def fromOption[A](option: => Option[A])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, None.type, Nothing, A]
  26. def fromQueue[Err, Done, Elem](queue: => Dequeue[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Err, Elem, Done]
  27. def fromZIO[R, E, A](zio: => ZIO[R, E, A])(implicit trace: Trace): ZChannel[R, Any, Any, Any, E, Nothing, A]
  28. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  29. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  30. def identity[Err, Elem, Done](implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Err, Elem, Done]
  31. def interruptAs(fiberId: => FiberId)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Nothing]
  32. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  33. 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]
  34. 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]
  35. 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]
  36. 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]
  37. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  38. final def never(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Nothing]

    Returns a channel that never completes

  39. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  40. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  41. 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]
  42. def read[In](implicit trace: Trace): ZChannel[Any, Any, In, Any, None.type, Nothing, In]
  43. def readOrFail[E, In](e: => E)(implicit trace: Trace): ZChannel[Any, Any, In, Any, E, Nothing, In]
  44. 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]
  45. 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]
  46. def refailCause[E](cause: Cause[E]): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]
  47. def scoped[R]: ScopedPartiallyApplied[R]
  48. def scopedWith[R, E, A](f: (Scope) => ZIO[R, E, A])(implicit trace: Trace): ZChannel[R, Any, Any, Any, E, A, Any]
  49. 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.

  50. def serviceAt[Service]: ServiceAtPartiallyApplied[Service]

    Accesses the service corresponding to the specified key in the environment.

  51. def serviceWith[Service]: ServiceWithPartiallyApplied[Service]

    Accesses the specified service in the environment of the channel.

  52. def serviceWithChannel[Service]: ServiceWithChannelPartiallyApplied[Service]

    Accesses the specified service in the environment of the channel in the context of a channel.

  53. def serviceWithZIO[Service]: ServiceWithZIOPartiallyApplied[Service]

    Accesses the specified service in the environment of the channel in the context of an effect.

  54. 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

  55. def succeedNow[Z](result: Z)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Z]
  56. def succeedWith[R, Z](f: (ZEnvironment[R]) => Z)(implicit trace: Trace): ZChannel[R, Any, Any, Any, Nothing, Nothing, Z]
  57. 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.

  58. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  59. def toHub[Err, Done, Elem](hub: => Hub[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Nothing, Nothing, Any]
  60. def toQueue[Err, Done, Elem](queue: => Enqueue[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Nothing, Nothing, Any]
  61. def toString(): String
    Definition Classes
    AnyRef → Any
  62. val unit: ZChannel[Any, Any, Any, Any, Nothing, Nothing, Unit]

    Channel that succeeds with the unit value

  63. 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]
  64. def unwrapScoped[Env]: UnwrapScopedPartiallyApplied[Env]
  65. def unwrapScopedWith[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone](f: (Scope) => ZIO[Env, OutErr, ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]])(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
  66. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  67. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  68. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  69. def write[Out](out: Out)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]
  70. def writeAll[Out](outs: Out*)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]
  71. def writeChunk[Out](outs: Chunk[Out])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]
  72. object Fold extends Serializable
  73. object MergeDecision
  74. object MergeStrategy

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  2. 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, mergeStrategy: BackPressure.type)(f: (OutDone, OutDone) => OutDone)(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]
    Annotations
    @deprecated
    Deprecated

    (Since version 2.1.7) use mergeAllWith with MergeStrategy

Inherited from AnyRef

Inherited from Any

Ungrouped