getChannel

abstract fun getChannel(subject: Subject, send: Flow<Map<String, String>>): Flow<RecordEvent>(source)

Opens a record channel on subject, sending each emitted field map from send to the server and emitting the server's record updates as RecordEvents.


abstract fun <T, R> getChannel(subject: Subject, send: Flow<T>, type: KClass<R & Any>): Flow<Event<R>>(source)

Opens a JSON channel on subject, sending each item from send to the server and emitting the server's updates deserialised to type.