serveStream_ method

  1. @visibleForTesting
ServerHandler serveStream_({
  1. required ServerTransportStream stream,
  2. X509Certificate? clientCertificate,
  3. InternetAddress? remoteAddress,
  4. Sink<void>? onDataReceived,
})

Implementation

@visibleForTesting
ServerHandler serveStream_({
  required ServerTransportStream stream,
  X509Certificate? clientCertificate,
  InternetAddress? remoteAddress,
  Sink<void>? onDataReceived,
}) {
  return ServerHandler(
      stream: stream,
      serviceLookup: lookupService,
      interceptors: _interceptors,
      codecRegistry: _codecRegistry,
      // ignore: unnecessary_cast
      clientCertificate: clientCertificate as io_bits.X509Certificate?,
      // ignore: unnecessary_cast
      remoteAddress: remoteAddress as io_bits.InternetAddress?,
      errorHandler: _errorHandler,
      onDataReceived: onDataReceived)
    ..handle();
}