Converts a callback producer to a bounded stream. Subscribes on the first read
of each execution. The returned cleanup runs once on completion, failure, or
cancellation. Synchronous emissions during subscribe count toward capacity.
No producer calls are awaited: use an explicit drop policy for lossy events.
Converts a callback producer to a bounded stream. Subscribes on the first read of each execution. The returned cleanup runs once on completion, failure, or cancellation. Synchronous emissions during subscribe count toward capacity. No producer calls are awaited: use an explicit drop policy for lossy events.