import type { Fn, NonZeroPositiveInteger, Result } from '@chzky/core';
import { UnexpectedError } from '@chzky/core';
/** ## `mux_pools` : 允许多协程执行的任务序列
任务队列中谁先执行完毕就返回谁
@example Usage
```ts
  const iter = mux_pools(
    Vec(number_generator(1, 5)).take(10).collect(),
    async (num) => {
      await sleep(10 * num)
      return Ok(num * 100)
    },
    2
  )

  const arr = await Array.fromAsync(iter)
  assert(arr.every(({ is_ok }) => is_ok))
  assert(arr.length == 4)
```
@param pools : 最大并发数,默认为无限制并发
@returns `AsyncIterableIterator<R | Result<never, UnexpectedError>>` - 返回一个异步迭代器
*/
export declare function mux_pools<T, R, N extends number>(iter: Iterable<T> | AsyncIterable<T>, iter_cb: Fn<T, Promise<R>>, pools?: NonZeroPositiveInteger<N>): AsyncIterableIterator<R | Result<never, UnexpectedError>>;
//# sourceMappingURL=muxPools.d.ts.map