parsedArriSseRequest<T> function
EventSource<T>
parsedArriSseRequest<T>(
- String url, {
- Client? httpClient,
- required HttpMethod method,
- required T parser(
- String data
- Map<
String, dynamic> ? params, - FutureOr<
Map< headers()?,String, String> > - Duration? retryDelay,
- int? maxRetryCount,
- SseHookOnMessage<
T> ? onMessage, - SseHookOnOpen<
T> ? onOpen, - SseHookOnClose<
T> ? onClose, - SseHookOnError<
T> ? onError, - String? lastEventId,
- String? clientVersion,
Implementation
EventSource<T> parsedArriSseRequest<T>(
String url, {
http.Client? httpClient,
required HttpMethod method,
required T Function(String data) parser,
Map<String, dynamic>? params,
FutureOr<Map<String, String>> Function()? headers,
Duration? retryDelay,
int? maxRetryCount,
SseHookOnMessage<T>? onMessage,
SseHookOnOpen<T>? onOpen,
SseHookOnClose<T>? onClose,
SseHookOnError<T>? onError,
String? lastEventId,
String? clientVersion,
}) {
return EventSource(
httpClient: httpClient,
url: url,
method: method,
parser: parser,
params: params,
headers: () async {
final result = await headers?.call() ?? {};
if (clientVersion != null && clientVersion.isNotEmpty) {
result["client-version"] = clientVersion;
}
return result;
},
retryDelay: retryDelay ?? Duration.zero,
maxRetryCount: maxRetryCount,
lastEventId: lastEventId,
onMessage: onMessage,
onOpen: onOpen,
onClose: onClose,
onError: onError,
);
}