AbstractConnectableStream<T, S extends Subject<T>, R extends Stream<T>> constructor

AbstractConnectableStream<T, S extends Subject<T>, R extends Stream<T>>(
  1. Stream<T> source,
  2. S subject
)

Constructs a AbstractConnectableStream with a source Stream and the forwarding Subject.

Implementation

AbstractConnectableStream(
  Stream<T> source,
  S subject,
)   : assert(subject is R),
      _source = source,
      _subject = subject,
      super(subject);