StreamOps

final class StreamOps[F[_], A](val stream: Stream[F, A])
class Object
trait Matchable
class Any

Value members

Concrete methods

def toUnicastPublisher(F: ConcurrentEffect[F]): StreamUnicastPublisher[F, A]

Creates a StreamUnicastPublisher from a stream.

Creates a StreamUnicastPublisher from a stream.

This publisher can only have a single subscription. The stream is only ran when elements are requested.

Concrete fields

val stream: Stream[F, A]