createResponseStreamFromRawRequest method

  1. @override
Stream<ServerTransportStream> createResponseStreamFromRawRequest(
  1. Socket request
)
override

Implementation

@override
Stream<ServerTransportStream> createResponseStreamFromRawRequest(
  Socket request,
) {
  var connection = ServerTransportConnection.viaSocket(
    request,
    settings: settings,
  );
  _connections.add(connection);
  request.done
      .then((_) {}, onError: (_) {})
      .whenComplete(() => _connections.remove(connection));
  return connection.incomingStreams;
}