connector-redis/com.river.connector.redis

Package-level declarations

Functions

Link copied to clipboard
@ExperimentalCoroutinesApi
fun RedissonClient.semaphore(    name: String,     concurrencyLevel: Int,     leaseTime: Duration = 10.seconds): suspend CoroutineScope.() -> AsyncSemaphore<String>

Returns a suspending function that creates an AsyncSemaphore using a Redisson semaphore. The semaphore is created the first time the returned function is invoked.