Skip to main content
Using Deno in production at your company? Earn free Deno merch.
Give us feedback
Module

x/grm/deps.ts>Semaphore

MTProto API Client for Deno 🦕
dcdunkan/grm
Go to Latest
class Semaphore
implements SemaphoreInterface
import { Semaphore } from "https://deno.land/x/grm@v0.3.1/deps.ts";

Constructors

new
Semaphore(_maxConcurrency: number, _cancelError?: Error)

Properties

private
_cancelError
private
_currentReleaser
private
_dispatch
private
_maxConcurrency
private
_queue
private
_resolveWaiters
private
_value
private
_waiters

Methods

acquire(): Promise<[number, SemaphoreInterface.Releaser]>
cancel(): void
isLocked(): boolean
deprecated
release(): void
runExclusive<T>(callback: SemaphoreInterface.Worker<T>): Promise<T>
waitForUnlock(): Promise<void>