Multiplexer<O> constructor

Multiplexer<O>(
  1. List<Stream> inputs,
  2. O mapper(
    1. List buffer
    )
)

Implementation

Multiplexer(this.inputs, this.mapper)
    : buffer = List<dynamic>.filled(inputs.length, null, growable: false) {
  _subscriptions = inputs
      .mapIndexed((input, i) => input.listen((event) => _onData(event, i)))
      .toList();
}