runtime/me.ahoo.wow.runtime.cluster/ClusterStream

ClusterStream

@InternalWowApi
fun interface ClusterStream

One stream to a peer, taken by ClusterChannel.reserve for one forward: forward sends it, after which the channel frees the stream once the reply ended it; release frees a stream no forward was sent on.

Functions

Link copied to clipboard
abstract suspend fun forward(request: ForwardCommand): ForwardReply

Sends request on this stream, as ClusterChannel.forward does; once.

Link copied to clipboard
open fun release()

Frees this stream when forward was not called; nothing after it.

Generated by Dokka
© 2026 Copyright