withoutConcurrency - accepts async functions and makes sure they run one after another, and never in parallel.
withCancelation - does the same thing, but also cancels all other async functions when a new function is scheduled. Useful for actions that override each other, like enabling and disabling camera.
createSafeAsyncSubscription adds an async listener to an Rx observable, and makes sure listeners never run in parallel, even if updates come in quicker than handlers can run.
Adds three concurrency helpers:
withoutConcurrency- accepts async functions and makes sure they run one after another, and never in parallel.withCancelation- does the same thing, but also cancels all other async functions when a new function is scheduled. Useful for actions that override each other, like enabling and disabling camera.createSafeAsyncSubscriptionadds an async listener to an Rx observable, and makes sure listeners never run in parallel, even if updates come in quicker than handlers can run.As an example, those utilities are adopted in two places, where ad-hoc solutions were previously added: https://github.com/GetStream/stream-video-js/pull/1371 https://github.com/GetStream/stream-video-js/pull/1342