QueryStreamsLifecycle

class QueryStreamsLifecycle(streams: QueryStreams) : SmartLifecycle

Ends every open query stream of the public port with end {"reason":"node-stopping","resumable":true}, and refuses new ones, as the node starts to stop: its clients resume them on another node.

Constructors

Link copied to clipboard
constructor(streams: QueryStreams)

Properties

Link copied to clipboard
open override val isRunning: Boolean
Link copied to clipboard
open override val phase: Int

Functions

Link copied to clipboard
open override fun getPhase(): Int
Link copied to clipboard
open override fun isRunning(): Boolean
Link copied to clipboard
open override fun start()
Link copied to clipboard
open override fun stop()