ParallelRequestExecutor class

Executes parallel request chains with proper type handling.

This executor processes ParallelRequest chains by:

  1. Executing the current step's filters against the Nostr service
  2. Adapting the results using the provided adapter function
  3. If a next step exists, recursively executing it with the adapted results
  4. All types are properly typed using generics for type safety

Constructors

ParallelRequestExecutor({required NostrService service})

Properties

hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

executeChain<T>({required ParallelRequest<T> rootRequest, List<NostrEvent>? initialEvents}) Future<Map<String, ParallelEventsRequestResponse>>
Executes a parallel request chain starting from the given root request.
executeMultipleChains<T>({required List<ParallelRequest<T>> requests, List<NostrEvent>? initialEvents}) Future<Map<int, Map<String, ParallelEventsRequestResponse>>>
Executes multiple parallel request chains concurrently.
executeSingleStep<T>({required ParallelRequest<T> request, List<NostrEvent>? initialEvents}) Future<List<T>>
Executes a single parallel request step without chaining.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited