Concat returns a concatenated Stream.

DoWithRetry 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.

WithRetry customize a DoWithRetry call with given retry times.

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.