ProtocolRunManager

class ProtocolRunManager<T : ProtocolStateMachine<U>, U>(timeoutDuration: Duration = 60.minutes)(source)

Holds a list of protocol runs for ProtocolMessenger, handling concurrency with a lock, as well as cleaning up old (client did not send a message again) and finished runs.

Constructors

Link copied to clipboard
constructor(timeoutDuration: Duration = 60.minutes)

Functions

Link copied to clipboard
suspend fun addProtocol(protocol: T)
Link copied to clipboard