serveConnection method

Future<void> serveConnection({ required ServerTransportConnection connection, X509Certificate? clientCertificate, InternetAddress? remoteAddress, })

Implementation

Future<void> serveConnection({
  required ServerTransportConnection connection,
  X509Certificate? clientCertificate,
  InternetAddress? remoteAddress,
}) async {
  _connections.add(connection);
  handlers[connection] = [];
  // TODO(jakobr): Set active state handlers, close connection after idle
  // timeout.
  final onDataReceivedController = StreamController<void>();
  ServerKeepAlive(
    options: _keepAliveOptions,
    tooManyBadPings: () async =>
        await connection.terminate(ErrorCode.ENHANCE_YOUR_CALM),
    pingNotifier: connection.onPingReceived,
    dataNotifier: onDataReceivedController.stream,
  ).handle();
  connection.incomingStreams.listen(
    (stream) {
      final handler = serveStream_(
        stream: stream,
        clientCertificate: clientCertificate,
        remoteAddress: remoteAddress,
        onDataReceived: onDataReceivedController.sink,
      );
      handler.onCanceled.then((_) => handlers[connection]?.remove(handler));
      handlers[connection]!.add(handler);
    },
    onError: (error, stackTrace) {
      if (error is Error) {
        Zone.current.handleUncaughtError(error, stackTrace);
      }
    },
    onDone: () async {
      // TODO(sigurdm): This is not correct behavior in the presence of
      // half-closed tcp streams.
      // Half-closed  streams seems to not be fully supported by package:http2.
      // https://github.com/dart-lang/http2/issues/42
      for (var handler in handlers[connection]!) {
        handler.cancel();
      }
      _connections.remove(connection);
      handlers.remove(connection);
      await onDataReceivedController.close();
    },
  );
}