SemaphoreModule
PackageAxial
Flow-native semaphore helpers.
Summary
| Name | Signature | Synopsis |
|---|---|---|
| make | Semaphore.make permits | Creates a semaphore with the supplied initial permit count. |
| withPermit | Semaphore.withPermit (FlowSemaphore queue) flow | Runs a workflow while holding one permit and always releases the permit afterward. |
Creates a semaphore with the supplied initial permit count.
Parameters
| Name | Type | Description |
|---|---|---|
| permits | int |
Returns
Flow<'env, 'error, FlowSemaphore>