serve method

Future<void> serve({ dynamic address, int? port, ServerCredentials? security, ServerSettings? http2ServerSettings, int backlog = 0, bool v6Only = false, bool shared = false, bool requestClientCertificate = false, bool requireClientCertificate = false, })

Starts the Server with the given options. address can be either a String or an InternetAddress, in the latter case it can be a Unix Domain Socket address.

If port is null then it defaults to 80 for non-secure and 443 for secure variants. Pass 0 for port to let OS select a port for the server.

Implementation

Future<void> serve({
  dynamic address,
  int? port,
  ServerCredentials? security,
  ServerSettings? http2ServerSettings,
  int backlog = 0,
  bool v6Only = false,
  bool shared = false,
  bool requestClientCertificate = false,
  bool requireClientCertificate = false,
}) async {
  // TODO(dart-lang/grpc-dart#9): Handle HTTP/1.1 upgrade to h2c, if allowed.
  Stream<Socket> server;
  final securityContext = security?.securityContext;
  if (securityContext != null) {
    final _server = await SecureServerSocket.bind(
      address ?? InternetAddress.anyIPv4,
      port ?? 443,
      securityContext,
      backlog: backlog,
      shared: shared,
      v6Only: v6Only,
      requestClientCertificate: requestClientCertificate,
      requireClientCertificate: requireClientCertificate,
    );
    _secureServer = _server;
    server = _server;
  } else {
    final _server = await ServerSocket.bind(
      address ?? InternetAddress.anyIPv4,
      port ?? 80,
      backlog: backlog,
      shared: shared,
      v6Only: v6Only,
    );
    _insecureServer = _server;
    server = _server;
  }
  server.listen(
    (socket) {
      // Don't wait for io buffers to fill up before sending requests.
      if (socket.address.type != InternetAddressType.unix) {
        socket.setOption(SocketOption.tcpNoDelay, true);
      }

      X509Certificate? clientCertificate;

      if (socket is SecureSocket) {
        clientCertificate = socket.peerCertificate;
      }

      final connection = ServerTransportConnection.viaSocket(
        socket,
        settings: http2ServerSettings,
      );

      serveConnection(
        connection: connection,
        clientCertificate: clientCertificate,
        remoteAddress: socket.remoteAddressOrNull,
      );
    },
    onError: (error, stackTrace) {
      if (error is Error) {
        Zone.current.handleUncaughtError(error, stackTrace);
      }
    },
  );
}