net/concurrent/concurrent library

Concurrent callback-based request support for RxNet

This library provides utilities for executing multiple callback-based network requests concurrently with type-safe result aggregation.

Classes

RequestState<T>

author:ZhengZaiHong email:[e-mail] date:2026-06-02 11:27 describe: 跟踪请求执行的内部状态 Internal state for tracking request execution

ZipRequest<T>

Wrapper for callback-based request methods with type information.

ZipRequestError

author:郑再红 email:[e-mail] date:2026-06-02 11:28 describe:带有上下文的请求错误包装器 Wrapper for request errors with context

ZipResults

author:ZhengZaiHong email:[e-mail] date:2026-06-02 11:27 describe: 通过zipRequest执行的并发请求聚合结果的容器。 Container for aggregated results from concurrent requests executed via zipRequest. ZipResults provides type-safe access to results from multiple concurrent requests, maintaining the original submission order and supporting both index-based and tag-based access.

Functions

createInternalCompleted<T>(ZipRequest<T> zipRequest) → Completed

Creates an internal completed callback (currently no-op). Kept for future extensibility.

createInternalFailure<T>(ZipRequest<T> zipRequest, Completer<T> completer, int index) → Failure

Creates an internal failure callback that completes the Completer with error. Captures stack trace for better error debugging.

createInternalSuccess<T>(ZipRequest<T> zipRequest, Completer<T> completer) → Success<T>

创建一个内部成功回调函数来完成Completer。 Creates an internal success callback that completes the Completer.

createRequestState<T>(ZipRequest<T> request, int index) → RequestState<T>

Factory function to create a typed RequestState This helps maintain type safety during request state initialization

invokeRequest<T>(ZipRequest<T> zipRequest, Success<T> internalSuccess, Failure internalFailure, Completed internalCompleted) → void

Invokes a request method with internal callbacks and user parameters merged. Internal callbacks take precedence over user parameters.

zipRequest(List<ZipRequest> requests, {bool eagerError = true, CancelToken? cancelToken, Duration? timeout}) → Future<ZipResults>

Main function to execute multiple callback-based requests concurrently.

Typedefs

ZipRequestFunction<T> = void Function({Completed? completed, Failure? failure, Success<T>? success})

author:ZhengZaiHong email:[e-mail] date:2026-05-29 9:46 describe: 基于回调的请求方法的类型定义 Type definition for callback-based request methods. This function type explicitly defines the three callback parameters that RxNet's async methods accept: success, failure, and completed.