rd-framework/com.jetbrains.rd.framework.impl/RdMap

RdMap

open class RdMap<K : Any, V : Any> : RdReactiveBase, IAsyncViewableMap<K, V> , IMutableViewableMap<K, V>

Constructors

RdMap

constructor(keySzr: ISerializer<K> = Polymorphic(), valSzr: ISerializer<V> = Polymorphic())

Types

Companion

object Companion : ISerializer<RdMap<*, *>>

Properties

async

open override var async: Boolean

If set to true, local changes to this object can be performed on any thread. Otherwise, local changes can be performed only on the UI thread.

bindState

var bindState: BindState

change

open override val change: ISource<IViewableMap.Event<K, V>>

changing

open val changing: Boolean

containingExt

val containingExt: RdExtBase?

entries

open override val entries: MutableSet<MutableMap.MutableEntry<K, V>>

isBound

val isBound: Boolean

isLocalChange

var isLocalChange: Boolean

keys

open override val keys: MutableSet<K>

keySzr

val keySzr: ISerializer<K>

location

override var location: RName

master

var master: Boolean

optimizeNested

var optimizeNested: Boolean

parent

var parent: IRdDynamic?

protocol

open override val protocol: IProtocol?

protocolOrThrow

val IRdDynamic.protocolOrThrow: IProtocol

rdid

open override var rdid: RdId

serializationContext

open override val serializationContext: SerializationCtx?

size

open override val size: Int

valSzr

val valSzr: ISerializer<V>

values

open override val values: MutableCollection<V>

Functions

advise

open override fun advise(lifetime: Lifetime, handler: (IViewableMap.Event<K, V>) -> Unit)

adviseAddRemove

open fun adviseAddRemove(lifetime: Lifetime, handler: (AddRemove, K, V) -> Unit)

adviseOn

open override fun adviseOn(lifetime: Lifetime, scheduler: IScheduler, handler: (IViewableMap.Event<K, V>) -> Unit)

adviseSuspend

fun <T> ISource<T>.~~adviseSuspend~~(lifetime: Lifetime, scheduler: IScheduler, handler: suspend (T) -> Unit)

fun <T> ISource<T>.~~adviseSuspend~~(lifetime: Lifetime, context: CoroutineContext, handler: suspend (T) -> Unit)

bind

open override fun bind()

Sends child objects to the wire. This method is called after the parent sends this instance to the wire.

clear

open override fun clear()

containsKey

open override fun containsKey(key: K): Boolean

containsValue

open override fun containsValue(value: V): Boolean

deepClone

open override fun deepClone(): IRdBindable

Creates a clone of this IRdBindable not bound to any protocol

findByRName

open override fun findByRName(rName: RName): RdBindableBase?

get

open operator override fun get(key: K): V?

getOrCreateExtension

inline fun <T : Any> getOrCreateExtension(name: String, noinline create: () -> T): T

fun <T : Any> getOrCreateExtension(name: String, clazz: KClass<T>, create: () -> T): T

getValue

operator fun <T : IRdBindable?> T.getValue(thisRef: Any?, property: KProperty<*>): T

operator fun <T : List<IRdBindable?>> T.getValue(thisRef: Any?, property: KProperty<*>): T

identify

open override fun identify(identities: IIdentities, id: RdId)

Assigns IDs to this node and its child nodes in the graph.

isEmpty

open override fun isEmpty(): Boolean

nextFalseValue

suspend fun ISource<Boolean>.~~nextFalseValue~~(lifetime: Lifetime = Lifetime.Eternal): Boolean

nextFalseValueAsync

fun ISource<Boolean>.~~nextFalseValueAsync~~(lifetime: Lifetime): Deferred<Boolean>

nextNotNullValue

suspend fun <T : Any> ISource<T?>.~~nextNotNullValue~~(lifetime: Lifetime = Lifetime.Eternal): T

nextNotNullValueAsync

fun <T : Any> ISource<T?>.~~nextNotNullValueAsync~~(lifetime: Lifetime): Deferred<T>

nextTrueValue

suspend fun ISource<Boolean>.~~nextTrueValue~~(lifetime: Lifetime = Lifetime.Eternal): Boolean

nextTrueValueAsync

fun ISource<Boolean>.~~nextTrueValueAsync~~(lifetime: Lifetime): Deferred<Boolean>

nextValue

suspend fun <T> ISource<T>.~~nextValue~~(lifetime: Lifetime = Lifetime.Eternal, condition: (T) -> Boolean = { true }): T

nextValueAsync

fun <T> ISource<T>.~~nextValueAsync~~(lifetime: Lifetime, condition: (T) -> Boolean = { true }): Deferred<T>

onWireReceived

override fun onWireReceived(buffer: AbstractBuffer, dispatchHelper: IRdWireableDispatchHelper)

Callback that wire triggers when it receives messaged

open override fun onWireReceived(proto: IProtocol, buffer: AbstractBuffer, ctx: SerializationCtx, dispatchHelper: IRdWireableDispatchHelper)

preBind

override fun preBind(lf: Lifetime, parent: IRdDynamic, name: String)

Inserts the node into the object graph under the given parent and assigns the specified name to it. The node will be removed from the graph when the specified lf lifetime is terminated.

open override fun print(printer: PrettyPrinter)

put

open override fun put(key: K, value: V): V?

putAll

open override fun putAll(from: Map<out K, V>)

remove

open override fun remove(key: K): V?

open override fun remove(key: K, value: V): Boolean

synchronizeWith

fun synchronizeWith(lifetime: Lifetime, otherBindable: RdBindableBase, accepts: (Any?) -> Boolean = { true })

toString

open override fun toString(): String

view

open override fun view(lifetime: Lifetime, handler: (Lifetime, Map.Entry<K, V>) -> Unit)

open fun view(lifetime: Lifetime, handler: (Lifetime, K, V) -> Unit)