SemaphoreModule

PackageAxial
Flow-native semaphore helpers.

Summary

NameSignatureSynopsis
Operations
makeSemaphore.make permitsCreates a semaphore with the supplied initial permit count.
withPermitSemaphore.withPermit semaphore flowRuns a workflow while holding one permit and always releases the permit afterward.

Operations

kind:member

make

Semaphore.make permits
Member
Creates a semaphore with the supplied initial permit count.

Parameters

NameTypeDescription
permitsint

Returns

Flow<'env, 'error, FlowSemaphore>
kind:member

withPermit

Semaphore.withPermit semaphore flow
Member
Runs a workflow while holding one permit and always releases the permit afterward.

Parameters

NameTypeDescription
semaphoreFlowSemaphore
flowFlow<'env, 'error, 'value>

Returns

Flow<'env, 'error, 'value>