Concat returns a concatenated Stream.

DoWithRetry runs fn, and retries if failed.

DoWithRetryCtx runs fn, and retries if failed.

DoWithTimeout runs fn with timeout control.

From constructs a Stream from the given GenerateFunc.

Just converts the given arbitrary items to a Stream.

Parallel runs fns parallelly and waits for done.

Range converts the given channel to a Stream.

UnlimitedWorkers lets the caller use as many workers as the tasks.

WithContext customizes a DoWithTimeout call with given ctx.

WithIgnoreErrors Ignore the specified errors.

WithInterval customizes a DoWithRetry call with given interval.

WithRetry customizes a DoWithRetry call with given retry times.

WithTimeout customizes a DoWithRetry call with given timeout.

WithWorkers lets the caller customize the concurrent workers.

ErrCanceled is the error returned when the context is canceled.

ErrTimeout is the error returned when the context's deadline passes.

DoOption defines the method to customize a DoWithTimeout call.