Module vibe.stream.semaphore
I/O concurrency limiting wrapper stream
Functions
Name | Description |
---|---|
createSemaphoreStream(stream, semaphore, lock_args)
|
Creates a new semaphore stream instance. |
Structs
Name | Description |
---|---|
SemaphoreStream
|
Limits the number concurrent blocking operations using a semaphore. |