( f: (entries: NonEmptyArray<Request.Entry<A>>) => Iterable<Request.Success<A>> )
| 391 | * @since 2.0.0 |
| 392 | */ |
| 393 | export const fromFunctionBatched = <A extends Request.Any>( |
| 394 | f: (entries: NonEmptyArray<Request.Entry<A>>) => Iterable<Request.Success<A>> |
| 395 | ): RequestResolver<A> => |
| 396 | make( |
| 397 | (entries) => |
| 398 | Effect.sync(() => { |
| 399 | let i = 0 |
| 400 | for (const result of f(entries)) { |
| 401 | const entry = entries[i++] |
| 402 | entry.completeUnsafe(exitSucceed(result)) |
| 403 | } |
| 404 | }) |
| 405 | ) |
| 406 | |
| 407 | /** |
| 408 | * Constructs a request resolver from an effectual function. |
nothing calls this directly
no test coverage detected