arrow-fx-stm/arrow.fx.stm/STM/release

release

open fun TSemaphore.release()(source)

Release a permit back to the TSemaphore.

import arrow.fx.stm.TSemaphore
import arrow.fx.stm.atomically

suspend fun main() {
  //sampleStart
  val tsem = TSemaphore.new(5)
  atomically {
    tsem.release()
  }
  //sampleEnd
  println("Permits remaining ${atomically { tsem.available() }}")
}
Content copied to clipboard

This function never retries.

open fun TSemaphore.release(n: Int)(source)

Release n permits back to the TSemaphore.

import arrow.fx.stm.TSemaphore
import arrow.fx.stm.atomically

suspend fun main() {
  //sampleStart
  val tsem = TSemaphore.new(5)
  atomically {
    tsem.release(2)
  }
  //sampleEnd
  println("Permits remaining ${atomically { tsem.available() }}")
}
Content copied to clipboard

n must be non-negative.

This function never retries.