couchbase-lite-ee/kotbase/MessageEndpointListener

MessageEndpointListener

expect class MessageEndpointListener(config: MessageEndpointListenerConfiguration)(source)

ENTERPRISE EDITION API

MessageEndpointListener to serve incoming message endpoint connection.

actual class MessageEndpointListener(config: MessageEndpointListenerConfiguration) : DelegatedClass<<Error class: unknown class>> (source)

actual class MessageEndpointListener(config: MessageEndpointListenerConfiguration)(source)

Constructors

MessageEndpointListener

expect constructor(config: MessageEndpointListenerConfiguration)

actual constructor(config: MessageEndpointListenerConfiguration)

actual constructor(config: MessageEndpointListenerConfiguration)

Functions

expect fun accept(connection: MessageEndpointConnection)

Accept a new connection.

actual fun accept(connection: MessageEndpointConnection)

actual fun accept(connection: MessageEndpointConnection)

addChangeListener

expect fun addChangeListener(listener: MessageEndpointListenerChangeListener): ListenerToken

Add a change listener.

expect fun addChangeListener(context: CoroutineContext, listener: MessageEndpointListenerChangeSuspendListener): ListenerToken

Add a change listener with a CoroutineContext that will be used to launch coroutines the listener will be called on. Coroutines will be launched in a CoroutineScope that is canceled when the listener is removed.

expect fun addChangeListener(scope: CoroutineScope, listener: MessageEndpointListenerChangeSuspendListener)

Add a change listener with a CoroutineScope that will be used to launch coroutines the listener will be called on. The listener is removed when the scope is canceled.

actual fun addChangeListener(listener: MessageEndpointListenerChangeListener): ListenerToken

actual fun addChangeListener(context: CoroutineContext, listener: MessageEndpointListenerChangeSuspendListener): ListenerToken

actual fun addChangeListener(scope: CoroutineScope, listener: MessageEndpointListenerChangeSuspendListener)

actual fun addChangeListener(listener: MessageEndpointListenerChangeListener): ListenerToken

actual fun addChangeListener(context: CoroutineContext, listener: MessageEndpointListenerChangeSuspendListener): ListenerToken

actual fun addChangeListener(scope: CoroutineScope, listener: MessageEndpointListenerChangeSuspendListener)

expect fun close(connection: MessageEndpointConnection)

Close the given connection.

actual fun close(connection: MessageEndpointConnection)

actual fun close(connection: MessageEndpointConnection)

expect fun closeAll()

Close all connections active at the time of the call.

actual fun closeAll()

actual fun closeAll()

open operator override fun equals(other: Any?): Boolean

open override fun hashCode(): Int

messageEndpointChangeFlow

fun MessageEndpointListener.messageEndpointChangeFlow(coroutineContext: CoroutineContext? = null): Flow<MessageEndpointListenerChange>

ENTERPRISE EDITION API

removeChangeListener

expect fun ~~removeChangeListener~~(token: ListenerToken)

Remove a change listener.

actual fun ~~removeChangeListener~~(token: ListenerToken)

actual fun ~~removeChangeListener~~(token: ListenerToken)

open override fun toString(): String