request method

  1. @override
Stream<Response> request(
  1. Request request, [
  2. NextLink? forward
])
override

A function called when a request reaches this Link

Implementation

@override
Stream<Response> request(Request request, [forward]) async* {
  if (_socketClient == null) {
    connectOrReconnect();
  }

  yield* _socketClient!.subscribe(request, true);
}