PublisherOps

final implicit class PublisherOps[A](val publisher: Publisher[A]) extends AnyVal

class AnyVal

trait Matchable

class Any

Value members

Creates a lazy stream from an org.reactivestreams.Publisher

Value parameters:

bufferSize: setup the number of elements asked each time from the org.reactivestreams.Publisher. A high number can be useful is the publisher is triggering from IO, like requesting elements from a database. The publisher can use this bufferSize to query elements in batch. A high number will also lead to more elements in memory.

@deprecated("Use toStreamBuffered method instead. Use a buffer size of 1 to keep the same behavior.", "3.1.4")

Creates a lazy stream from an org.reactivestreams.Publisher