LiveQueryFlow

class LiveQueryFlow<T>(flow: Flow<LiveQueryAction<T>>, val id: String, connection: Surreal) : Flow<LiveQueryAction<T>> , Closeable

Live query flow

This class is a wrapper around a flow of LiveQueryActions making it Closeable.

Parameters

T

The type of the records

Constructors

Link copied to clipboard
constructor(flow: Flow<LiveQueryAction<T>>, id: String, connection: Surreal)

Creates a new live query flow

Properties

Link copied to clipboard
val id: String

The id of the live query

Functions

Link copied to clipboard
open override fun close()

Close

Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<LiveQueryAction<T>>)
Link copied to clipboard
fun <R> map(transform: (LiveQueryAction<T>) -> LiveQueryAction<R>): LiveQueryFlow<R>

Map