ZChannel

zio.stream.ZChannel
See theZChannel companion trait
object ZChannel

Attributes

Companion
trait
Source
ZChannel.scala
Graph
Supertypes
trait Sum
trait Mirror
class Object
trait Matchable
class Any
Self type
ZChannel.type

Members list

Type members

Classlikes

final class EnvironmentWithChannelPartiallyApplied[Env](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class EnvironmentWithPartiallyApplied[Env](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class EnvironmentWithZIOPartiallyApplied[Env](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
object Fold

Attributes

Source
ZChannel.scala
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
Fold.type
sealed abstract class MergeDecision[-R, -E0, -Z0, +E, +Z]

Attributes

Companion
object
Source
ZChannel.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Await[R, E0, Z0, E, Z]
class Done[R, E, Z]
object MergeDecision

Attributes

Companion
class
Source
ZChannel.scala
Supertypes
trait Sum
trait Mirror
class Object
trait Matchable
class Any
Self type
object MergeStrategy

Attributes

Companion
trait
Source
ZChannel.scala
Supertypes
trait Sum
trait Mirror
class Object
trait Matchable
class Any
Self type
sealed trait MergeStrategy

Attributes

Companion
object
Source
ZChannel.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
object BackPressure
object BufferSliding
final class ProvideSomeLayer[Env0, -Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone](self: ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class ScopedPartiallyApplied[R](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class ServiceAtPartiallyApplied[Service](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class ServiceWithChannelPartiallyApplied[Service](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class ServiceWithPartiallyApplied[Service](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class ServiceWithZIOPartiallyApplied[Service](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class UnwrapScopedPartiallyApplied[Env](dummy: Boolean = ...) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class UpdateService[-Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone, Service](self: ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any
final class UpdateServiceAt[-Env, -InErr, -InElem, -InDone, +OutErr, +OutElem, +OutDone, Service](self: ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]) extends AnyVal

Attributes

Source
ZChannel.scala
Supertypes
class AnyVal
trait Matchable
class Any

Inherited and Abstract types

type MirroredElemLabels <: Tuple

The names of the product elements

The names of the product elements

Attributes

Inherited from:
Mirror
Source
Mirror.scala
type MirroredLabel <: String

The name of the type

The name of the type

Attributes

Inherited from:
Mirror
Source
Mirror.scala

Value members

Concrete methods

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]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
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. 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.

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.

Attributes

Source
ZChannel.scala
def bufferChunk[InErr, InElem, InDone](ref: => Ref[Chunk[InElem]])(implicit trace: Trace): ZChannel[Any, InErr, Chunk[InElem], InDone, InErr, Chunk[InElem], InDone]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
def environment[Env](implicit trace: Trace): ZChannel[Env, Any, Any, Any, Nothing, Nothing, ZEnvironment[Env]]

Accesses the whole environment of the channel.

Accesses the whole environment of the channel.

Attributes

Source
ZChannel.scala
def environmentWith[Env]: EnvironmentWithPartiallyApplied[Env]

Accesses the environment of the channel.

Accesses the environment of the channel.

Attributes

Source
ZChannel.scala
def environmentWithChannel[Env]: EnvironmentWithChannelPartiallyApplied[Env]

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

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

Attributes

Source
ZChannel.scala
def environmentWithZIO[Env]: EnvironmentWithZIOPartiallyApplied[Env]

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

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

Attributes

Source
ZChannel.scala
def fail[E](e: => E)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]

Attributes

Source
ZChannel.scala
def failCause[E](cause: => Cause[E])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]

Attributes

Source
ZChannel.scala
def fromEither[E, A](either: => Either[E, A])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, E, Nothing, A]

Attributes

Source
ZChannel.scala
def fromHub[Err, Done, Elem](hub: => Hub[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Err, Elem, Done]

Attributes

Source
ZChannel.scala
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]]

Attributes

Source
ZChannel.scala
def fromOption[A](option: => Option[A])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, None.type, Nothing, A]

Attributes

Source
ZChannel.scala
def fromQueue[Err, Done, Elem](queue: => Dequeue[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Err, Elem, Done]

Attributes

Source
ZChannel.scala
def fromZIO[R, E, A](zio: => ZIO[R, E, A])(implicit trace: Trace): ZChannel[R, Any, Any, Any, E, Nothing, A]

Attributes

Source
ZChannel.scala
def identity[Err, Elem, Done](implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Err, Elem, Done]

Attributes

Source
ZChannel.scala
def interruptAs(fiberId: => FiberId)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Nothing]

Attributes

Source
ZChannel.scala
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 = ..., mergeStrategy: => MergeStrategy = ...)(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, Any]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
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: => MergeStrategy = ...)(f: (OutDone, OutDone) => OutDone)(implicit trace: Trace): ZChannel[Env, InErr, InElem, InDone, OutErr, OutElem, OutDone]

Attributes

Source
ZChannel.scala
final def never(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Nothing]

Returns a channel that never completes

Returns a channel that never completes

Attributes

Source
ZChannel.scala
def provideLayer[Env0, Env, Env1, InErr, InElem, InDone, OutErr, OutElem, OutDone](layer: ZLayer[Env0, OutErr, Env])(channel: => ZChannel[Env & Env1, InErr, InElem, InDone, OutErr, OutElem, OutDone])(implicit ev: Tag[Env], tag: Tag[Env1], trace: Trace): ZChannel[Env0 & Env1, InErr, InElem, InDone, OutErr, OutElem, OutDone]

Attributes

Source
ZChannel.scala
def read[In](implicit trace: Trace): ZChannel[Any, Any, In, Any, None.type, Nothing, In]

Attributes

Source
ZChannel.scala
def readOrFail[E, In](e: => E)(implicit trace: Trace): ZChannel[Any, Any, In, Any, E, Nothing, In]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
def refailCause[E](cause: Cause[E]): ZChannel[Any, Any, Any, Any, E, Nothing, Nothing]

Attributes

Source
ZChannel.scala
def scoped[R]: ScopedPartiallyApplied[R]

Attributes

Source
ZChannel.scala
def scopedWith[R, E, A](f: Scope => ZIO[R, E, A])(implicit trace: Trace): ZChannel[R, Any, Any, Any, E, A, Any]

Attributes

Source
ZChannel.scala
def service[Service : Tag](implicit evidence$1: Tag[Service], trace: Trace): ZChannel[Service, Any, Any, Any, Nothing, Nothing, Service]

Accesses the specified service in the environment of the channel.

Accesses the specified service in the environment of the channel.

Attributes

Source
ZChannel.scala
def serviceAt[Service]: ServiceAtPartiallyApplied[Service]

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

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

Attributes

Source
ZChannel.scala
def serviceWith[Service]: ServiceWithPartiallyApplied[Service]

Accesses the specified service in the environment of the channel.

Accesses the specified service in the environment of the channel.

Attributes

Source
ZChannel.scala
def serviceWithChannel[Service]: ServiceWithChannelPartiallyApplied[Service]

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

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

Attributes

Source
ZChannel.scala
def serviceWithZIO[Service]: ServiceWithZIOPartiallyApplied[Service]

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

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

Attributes

Source
ZChannel.scala
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

Creates a channel that succeeds immediately with the given value

Attributes

Source
ZChannel.scala
def succeedNow[Z](result: Z)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Nothing, Z]

Attributes

Source
ZChannel.scala
def succeedWith[R, Z](f: (ZEnvironment[R]) => Z)(implicit trace: Trace): ZChannel[R, Any, Any, Any, Nothing, Nothing, Z]

Attributes

Source
ZChannel.scala
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.

Returns a lazily constructed channel.

Attributes

Source
ZChannel.scala
def toHub[Err, Done, Elem](hub: => Hub[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Nothing, Nothing, Any]

Attributes

Source
ZChannel.scala
def toQueue[Err, Done, Elem](queue: => Enqueue[Either[Exit[Err, Done], Elem]])(implicit trace: Trace): ZChannel[Any, Err, Elem, Done, Nothing, Nothing, Any]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
def unwrapScoped[Env]: UnwrapScopedPartiallyApplied[Env]

Attributes

Source
ZChannel.scala
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]

Attributes

Source
ZChannel.scala
def write[Out](out: Out)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]

Attributes

Source
ZChannel.scala
def writeAll[Out](outs: Out*)(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]

Attributes

Source
ZChannel.scala
def writeChunk[Out](outs: Chunk[Out])(implicit trace: Trace): ZChannel[Any, Any, Any, Any, Nothing, Out, Unit]

Attributes

Source
ZChannel.scala

Deprecated methods

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]

Attributes

Deprecated
[Since version 2.1.7] use mergeAllWith with `MergeStrategy`
Source
ZChannel.scala

Concrete fields

val unit: ZChannel[Any, Any, Any, Any, Nothing, Nothing, Unit]

Channel that succeeds with the unit value

Channel that succeeds with the unit value

Attributes

Source
ZChannel.scala