ZManagedZStreamCompanionSyntax

zio.managed.`package`.ZManagedZStreamCompanionSyntax
final implicit class ZManagedZStreamCompanionSyntax(self: ZStream.type) extends AnyVal

Attributes

Source
package.scala
Graph
Supertypes
class AnyVal
trait Matchable
class Any

Members list

Value members

Concrete methods

def fromChunkHubManaged[O](hub: => Hub[Chunk[O]])(implicit trace: Trace): ZManaged[Any, Nothing, ZStream[Any, Nothing, O]]

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

Attributes

Source
package.scala
def fromChunkHubManagedWithShutdown[O](hub: => Hub[Chunk[O]])(implicit trace: Trace): ZManaged[Any, Nothing, ZStream[Any, Nothing, O]]

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

The hub will be shut down once the stream is closed.

Attributes

Source
package.scala
def fromHubManaged[A](hub: => Hub[A], maxChunkSize: => Int = ...)(implicit trace: Trace): ZManaged[Any, Nothing, ZStream[Any, Nothing, A]]

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

Attributes

Source
package.scala
def fromHubManagedWithShutdown[A](hub: => Hub[A], maxChunkSize: => Int = ...)(implicit trace: Trace): ZManaged[Any, Nothing, ZStream[Any, Nothing, A]]

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

Creates a stream from a subscription to a hub in the context of a managed effect. The managed effect describes subscribing to receive messages from the hub while the stream describes taking messages from the hub.

The hub will be shut down once the stream is closed.

Attributes

Source
package.scala
def fromInputStreamManaged[R](is: => ZManaged[R, IOException, InputStream], chunkSize: => Int = ...)(implicit trace: Trace): ZStream[R, IOException, Byte]

Creates a stream from a managed java.io.InputStream value.

Creates a stream from a managed java.io.InputStream value.

Attributes

Source
package.scala
def fromIteratorManaged[R, A](iterator: => ZManaged[R, Throwable, Iterator[A]], maxChunkSize: => Int = ...)(implicit trace: Trace): ZStream[R, Throwable, A]

Creates a stream from a managed iterator

Creates a stream from a managed iterator

Attributes

Source
package.scala
def fromJavaIteratorManaged[R, A](iterator: => ZManaged[R, Throwable, Iterator[A]])(implicit trace: Trace): ZStream[R, Throwable, A]

Creates a stream from a managed iterator

Creates a stream from a managed iterator

Attributes

Source
package.scala
def fromJavaIteratorManaged[R, A](iterator: => ZManaged[R, Throwable, Iterator[A]], chunkSize: Int)(implicit trace: Trace): ZStream[R, Throwable, A]

Creates a stream from a managed iterator

Creates a stream from a managed iterator

Attributes

Source
package.scala
def managed[R, E, A](managed: => ZManaged[R, E, A])(implicit trace: Trace): ZStream[R, E, A]

Attributes

Source
package.scala
def unwrapScoped[R, E, A](fa: => ZManaged[R, E, ZStream[R, E, A]])(implicit trace: Trace): ZStream[R, E, A]

Attributes

Source
package.scala