def fetch.all.go

bend-kit-http@0.38.5.0 · http.bend:4363

import Base
import bend-kit-concurrency@0.2.0.0/concurrency.bend as Conc

4363# No requests start no workers, since Conc.pool needs at least one.
4364def fetch.all.go(xs: List<Fetch>, +workers: Nat) -> IO(List<Result<&1, &1, Err, Res>>):
4365  match xs:
4366    case Nil{}:
4367      IO.pure(List<Result<&1, &1, Err, Res>>, Nil{})
4368    case x <> rest:
4369      do IO<List<Result<&1, &1, Err, Res>>>:
4370        r : List<Pool> & List<Result<&1, &1, Err, Res>> <-
4371          Conc.pool(~Pool, ~Fetch, ~Result<&1, &1, Err, Res>, ~fetch.all.job, fetch.all.pools(workers), x <> rest)
4372        fetch.all.done(r)