StreamSubscriber

final class StreamSubscriber[F[_], A](val sub: FSM[F, A])(implicit F: ApplicativeError[F, Throwable]) extends Subscriber[A]

Implementation of a org.reactivestreams.Subscriber.

This is used to obtain a fs2.Stream from an upstream reactivestreams system.

See also:: https://github.com/reactive-streams/reactive-streams-jvm#2-subscriber-code
Companion:: object

trait Subscriber[A]

class Object

trait Matchable

class Any

Value members

@deprecated("Use a constructor without dispatcher instead", "3.1.4")

Called by an upstream reactivestreams system