VmServerConnection constructor Null safety

VmServerConnection(
  1. Stream<Map<String, Object>> _requestStream,
  2. StreamSink<Map<String, Object?>> _responseSink,
  3. ServiceExtensionRegistry _serviceExtensionRegistry,
  4. VmServiceInterface _serviceImplementation
)

Implementation

VmServerConnection(this._requestStream, this._responseSink,
    this._serviceExtensionRegistry, this._serviceImplementation) {
  _requestStream.listen(_delegateRequest, onDone: _doneCompleter.complete);
  done.then(
      (_) => _streamSubscriptions.values.forEach((sub) => sub.cancel()));
}