t

zio.stream

ZStreamPlatformSpecificConstructors

trait ZStreamPlatformSpecificConstructors extends AnyRef

Self Type
ZStream.type
Linear Supertypes
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZStreamPlatformSpecificConstructors
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final class Connection extends AnyRef

    Accepted connection made to a specific channel AsynchronousServerSocketChannel

  2. trait ZStreamConstructorPlatformSpecific extends ZStreamConstructorLowPriority1

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def async[R, E, A](register: (Emit[R, E, A, Unit]) => Unit, outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times.

    Creates a stream from an asynchronous callback that can be called multiple times. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

  6. def asyncInterrupt[R, E, A](register: (Emit[R, E, A, Unit]) => Either[Canceler[R], ZStream[R, E, A]], outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times.

    Creates a stream from an asynchronous callback that can be called multiple times. The registration of the callback returns either a canceler or synchronously returns a stream. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

  7. def asyncManaged[R, E, A](register: ((ZIO[R, Option[E], Chunk[A]]) => Unit) => ZManaged[R, E, Any], outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times.

    Creates a stream from an asynchronous callback that can be called multiple times. The registration of the callback itself returns an a managed resource. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

  8. def asyncMaybe[R, E, A](register: (Emit[R, E, A, Unit]) => Option[ZStream[R, E, A]], outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times.

    Creates a stream from an asynchronous callback that can be called multiple times. The registration of the callback can possibly return the stream synchronously. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

  9. def asyncZIO[R, E, A](register: (Emit[R, E, A, Unit]) => ZIO[R, E, Any], outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times The registration of the callback itself returns an effect.

    Creates a stream from an asynchronous callback that can be called multiple times The registration of the callback itself returns an effect. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

  10. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  14. def fromFile(path: => Path, chunkSize: Int = ZStream.DefaultChunkSize)(implicit trace: ZTraceElement): ZStream[Any, Throwable, Byte]

    Creates a stream of bytes from a file at the specified path.

  15. final def fromJavaStream[A](stream: => java.util.stream.Stream[A])(implicit trace: ZTraceElement): ZStream[Any, Throwable, A]

    Creates a stream from a Java stream

  16. final def fromJavaStreamManaged[R, A](stream: ZManaged[R, Throwable, java.util.stream.Stream[A]])(implicit trace: ZTraceElement): ZStream[R, Throwable, A]

    Creates a stream from a managed Java stream

  17. final def fromJavaStreamSucceed[R, A](stream: => java.util.stream.Stream[A])(implicit trace: ZTraceElement): ZStream[R, Nothing, A]

    Creates a stream from a Java stream

  18. final def fromJavaStreamZIO[R, A](stream: ZIO[R, Throwable, java.util.stream.Stream[A]])(implicit trace: ZTraceElement): ZStream[R, Throwable, A]

    Creates a stream from a Java stream

  19. def fromOutputStreamWriter(write: (OutputStream) => Unit, chunkSize: Int = ZStream.DefaultChunkSize)(implicit trace: ZTraceElement): ZStream[Any, Throwable, Byte]

    Creates a stream from a callback that writes to java.io.OutputStream.

    Creates a stream from a callback that writes to java.io.OutputStream. Note: the input stream will be closed after the write is done.

  20. def fromReader(reader: => Reader, chunkSize: Int = ZStream.DefaultChunkSize)(implicit trace: ZTraceElement): ZStream[Any, IOException, Char]

    Creates a stream from java.io.Reader.

  21. def fromReaderManaged[R](reader: => ZManaged[R, IOException, Reader], chunkSize: Int = ZStream.DefaultChunkSize)(implicit trace: ZTraceElement): ZStream[R, IOException, Char]

    Creates a stream from managed java.io.Reader.

  22. def fromReaderZIO[R](reader: => ZIO[R, IOException, Reader], chunkSize: Int = ZStream.DefaultChunkSize)(implicit trace: ZTraceElement): ZStream[R, IOException, Char]

    Creates a stream from an effect producing java.io.Reader.

  23. final def fromResource(path: String, chunkSize: Int = ZStream.DefaultChunkSize)(implicit trace: ZTraceElement): ZStream[Any, IOException, Byte]

    Creates a stream from the resource specified in path

  24. def fromSocketServer(port: Int, host: Option[String] = None)(implicit trace: ZTraceElement): ZStream[Any, Throwable, ZStream.Connection]

    Create a stream of accepted connection from server socket Emit socket Connection from which you can read / write and ensure it is closed after it is used

  25. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  26. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  27. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  28. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  29. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  30. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  31. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  32. def toString(): String
    Definition Classes
    AnyRef → Any
  33. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  34. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  35. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  36. object Connection

Deprecated Value Members

  1. def effectAsync[R, E, A](register: (Emit[R, E, A, Unit]) => Unit, outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times.

    Creates a stream from an asynchronous callback that can be called multiple times. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use async

  2. def effectAsyncInterrupt[R, E, A](register: (Emit[R, E, A, Unit]) => Either[Canceler[R], ZStream[R, E, A]], outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times.

    Creates a stream from an asynchronous callback that can be called multiple times. The registration of the callback returns either a canceler or synchronously returns a stream. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use asyncInterrupt

  3. def effectAsyncM[R, E, A](register: (Emit[R, E, A, Unit]) => ZIO[R, E, Any], outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times The registration of the callback itself returns an effect.

    Creates a stream from an asynchronous callback that can be called multiple times The registration of the callback itself returns an effect. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use asyncZIO

  4. def effectAsyncMaybe[R, E, A](register: (Emit[R, E, A, Unit]) => Option[ZStream[R, E, A]], outputBuffer: Int = 16)(implicit trace: ZTraceElement): ZStream[R, E, A]

    Creates a stream from an asynchronous callback that can be called multiple times.

    Creates a stream from an asynchronous callback that can be called multiple times. The registration of the callback can possibly return the stream synchronously. The optionality of the error type E can be used to signal the end of the stream, by setting it to None.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use asyncMaybe

  5. final def fromJavaStreamEffect[R, A](stream: ZIO[R, Throwable, java.util.stream.Stream[A]])(implicit trace: ZTraceElement): ZStream[R, Throwable, A]

    Creates a stream from a Java stream

    Creates a stream from a Java stream

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use fromJavaStreamZIO

  6. final def fromJavaStreamTotal[A](stream: => java.util.stream.Stream[A])(implicit trace: ZTraceElement): ZStream[Any, Nothing, A]

    Creates a stream from a Java stream

    Creates a stream from a Java stream

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use fromJavaStreamSucceed

  7. def fromReaderEffect[R](reader: => ZIO[R, IOException, Reader], chunkSize: Int = ZStream.DefaultChunkSize)(implicit trace: ZTraceElement): ZStream[R, IOException, Char]

    Creates a stream from an effect producing java.io.Reader.

    Creates a stream from an effect producing java.io.Reader.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use fromReaderZIO

Inherited from AnyRef

Inherited from Any

Ungrouped