Packages

p

zio

stream

package stream

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

Package Members

  1. package compression
  2. package internal

Type Members

  1. type Sink[+E, A, +L, +B] = ZSink[Any, E, A, L, B]
  2. type Stream[+E, +A] = ZStream[Any, E, A]
  3. final class SubscriptionRef[A] extends AnyRef

    A SubscriptionRef[A] contains a RefM with a value of type A and a ZStream that can be subscribed to in order to receive the current value as well as all changes to the value.

  4. final case class Take[+E, +A](exit: Exit[Option[E], Chunk[A]]) extends AnyVal with Product with Serializable

    A Take[E, A] represents a single take from a queue modeling a stream of values.

    A Take[E, A] represents a single take from a queue modeling a stream of values. A Take may be a failure cause Cause[E], an chunk value A or an end-of-stream marker.

  5. type Transducer[+E, -A, +B] = ZTransducer[Any, E, A, B]
  6. type UStream[+A] = ZStream[Any, Nothing, A]
  7. abstract class ZSink[-R, +E, -I, +L, +Z] extends AnyRef
  8. trait ZSinkPlatformSpecificConstructors extends AnyRef
  9. abstract class ZStream[-R, +E, +O] extends AnyRef

    A ZStream[R, E, O] is a description of a program that, when evaluated, may emit 0 or more values of type O, may fail with errors of type E and uses an environment of type R.

    A ZStream[R, E, O] is a description of a program that, when evaluated, may emit 0 or more values of type O, may fail with errors of type E and uses an environment of type R. One way to think of ZStream is as a ZIO program that could emit multiple values.

    Another analogue to ZStream is an imperative iterator:

    trait Iterator[A] {
      def next: A
    }

    This data type can emit multiple A values through multiple calls to next. Similarly, embedded inside every ZStream is a ZIO program: ZIO[R, Option[E], Chunk[O]]. This program will be repeatedly evaluated as part of the stream execution. For every evaluation, it will emit a chunk of values or end with an optional failure. A failure of type None signals the end of the stream.

    ZStream is a purely functional *pull* based stream. Pull based streams offer inherent laziness and backpressure, relieving users of the need to manage buffers between operators. As an optimization, ZStream does not emit single values, but rather zio.Chunk values. This allows the cost of effect evaluation to be amortized and most importantly, keeps primitives unboxed. This allows ZStream to model network and file-based stream processing extremely efficiently.

    The last important attribute of ZStream is resource management: it makes heavy use of ZManaged to manage resources that are acquired and released during the stream's lifetime.

    ZStream forms a monad on its O type parameter, and has error management facilities for its E type parameter, modeled similarly to ZIO (with some adjustments for the multiple-valued nature of ZStream). These aspects allow for rich and expressive composition of streams.

    The current encoding of ZStream is *not* safe for recursion. ZStream programs that are defined in terms of themselves will leak memory. For example, the following implementation of ZStream#forever is not heap-safe:

    def forever = self ++ forever

    Instead, recursive operators must be defined explicitly. See the definition of ZStream#forever for an example. This limitation will be lifted in the future.

  10. trait ZStreamPlatformSpecificConstructors extends AnyRef
  11. abstract class ZTransducer[-R, +E, -I, +O] extends AnyRef
  12. trait ZTransducerPlatformSpecificConstructors extends AnyRef

Value Members

  1. val Sink: ZSink.type
  2. val Stream: ZStream.type
  3. val Transducer: ZTransducer.type
  4. val UStream: ZStream.type
  5. case object BuildInfo extends Product with Serializable

    This object was generated by sbt-buildinfo.

  6. object SubscriptionRef
  7. object Take extends Serializable
  8. object ZSink extends ZSinkPlatformSpecificConstructors
  9. object ZStream extends ZStreamPlatformSpecificConstructors
  10. object ZTransducer extends ZTransducerPlatformSpecificConstructors

Inherited from AnyRef

Inherited from Any

Ungrouped