ktor-network/io.ktor.network.selector/InterestSuspensionsMap

InterestSuspensionsMap

A thread-safe map that manages suspensions for different SelectInterest types.

This class is used internally by the selector to track coroutine continuations waiting for specific I/O operations (read, write, accept, connect) to become ready.

Report a problem

Constructors

constructor()

Types

Companion

object Companion

Functions

addSuspension

fun addSuspension(interest: SelectInterest, continuation: CancellableContinuation<Unit>)

Registers a suspension continuation for the specified interest.

invokeForEachPresent

inline fun invokeForEachPresent(block: CancellableContinuation<Unit>.(SelectInterest) -> Unit)

Invokes the given block for each registered suspension, regardless of ready state. The suspensions are removed from the map before invoking the block. This is typically used for cleanup or cancellation.

inline fun invokeForEachPresent(readyOps: Int, block: CancellableContinuation<Unit>.() -> Unit)

Invokes the given block for each registered suspension whose interest matches the readyOps flags. The matching suspensions are removed from the map before invoking the block.

removeSuspension

fun removeSuspension(interest: SelectInterest): CancellableContinuation<Unit>?

Removes and returns the suspension registered for the specified interest.

fun removeSuspension(interestOrdinal: Int): CancellableContinuation<Unit>?

Removes and returns the suspension registered for the interest at the given ordinal index.

toString

open override fun toString(): String