fs2-reactive-streams/fs2.interop.reactivestreams/StreamSubscriber

StreamSubscriber

object StreamSubscriber
Companion:
class
class Object
trait Matchable
class Any

Value members

Concrete methods

def apply[F[_] : Async, A](bufferSize: Int): F[StreamSubscriber[F, A]]

Deprecated methods

@deprecated("Use apply method with a buffer size. Use a buffer size of 1 to keep the same behavior.", "3.1.4")
def apply[F[_] : Async, A]: F[StreamSubscriber[F, A]]
Deprecated
@deprecated("Use apply method without dispatcher instead", "3.1.4")
def apply[F[_] : Async, A](dispatcher: Dispatcher[F]): F[StreamSubscriber[F, A]]
Deprecated