AsyncProxyController<T> constructor

AsyncProxyController<T>({String $serviceName, String $interfaceName})

Implementation

AsyncProxyController({this.$serviceName, this.$interfaceName}) {
  _reader
    ..onReadable = _handleReadable
    ..onError = _handleError;
  whenClosed.then((_) {
    for (final Completer completer in _completerMap.values) {
      if (!completer.isCompleted) {
        completer.completeError(FidlError(
            'AsyncProxyController<${$interfaceName}> connection closed'));
      }
    }
    _completerMap.clear();
  }, onError: (_) {
    // Ignore errors.
  });
}