concurrentFetcher records the maximum number of in-flight Fetch calls so we can assert downloads actually run in parallel, and produces a deterministic one-skill repo so results are checkable.
| 13 | // can assert downloads actually run in parallel, and produces a deterministic |
| 14 | // one-skill repo so results are checkable. |
| 15 | type concurrentFetcher struct { |
| 16 | inFlight atomic.Int32 |
| 17 | maxSeen atomic.Int32 |
| 18 | calls atomic.Int32 |
| 19 | } |
| 20 | |
| 21 | func (c *concurrentFetcher) Fetch(owner, repo, branch, dest string) (string, error) { |
| 22 | c.calls.Add(1) |
nothing calls this directly
no outgoing calls
no test coverage detected