TypeSafeSDK.Batch (TypeSafeSDK v0.4.0)

Copy Markdown View Source

Lazy, bounded evaluation using an owned supervisor and unlinked tasks.

The stream is cold and re-enumerable. Every enumeration owns its supervisor; early halt and errors stop remaining tasks. This bounds tasks in this batch, not queues in the shared HTTP transport. Ordered evaluation uses bounded prefetch windows (max_pending, default four times concurrency); one window completes before the next starts. Unordered results retain batch_index.

Summary

Functions

many(client, states, questions, opts \\ [])

@spec many(TypeSafeSDK.Client.t(), Enumerable.t(), term(), keyword()) :: list()

stream(client, states, questions, opts \\ [])