TestSseClient.internal constructor

TestSseClient.internal({
  1. required UnmodifiableMapView<String, String> headers,
  2. required Duration connectTimeout,
  3. required Duration readTimeout,
  4. required String? body,
  5. required SseHttpMethod httpMethod,
  6. Stream<Event>? sourceStream,
})

Implementation

TestSseClient.internal({
  required this.headers,
  required this.connectTimeout,
  required this.readTimeout,
  required this.body,
  required this.httpMethod,
  Stream<Event>? sourceStream,
}) {
  _sourceStream = sourceStream;
  _messageEventsController = StreamController<Event>.broadcast(
    onListen: () {
      _sourceStreamSubscription = _sourceStream?.listen((event) {
        emitEvent(event);
      });
      _sourceStreamSubscription?.onError((error) {
        emitError();
      });
    },
    onCancel: () {
      _sourceStreamSubscription?.cancel();
    },
  );
}