rd-kt/rd-framework/src/main/kotlin/com/jetbrains/rd/framework/impl/AsyncRdMap.kt [210:227]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - override fun assertBindingThread() { } override fun assertThreading() { } override fun onWireReceived(proto: IProtocol, buffer: AbstractBuffer, ctx: SerializationCtx, dispatchHelper: IRdWireableDispatchHelper) { synchronized(this) { super.onWireReceived(proto, buffer, ctx, object : IRdWireableDispatchHelper { override val rdId: RdId get() = dispatchHelper.rdId override val lifetime: Lifetime get() = dispatchHelper.lifetime override fun dispatch(scheduler: IScheduler?, action: () -> Unit) { dispatchHelper.dispatch(SynchronousScheduler, action) } }) - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - rd-kt/rd-framework/src/main/kotlin/com/jetbrains/rd/framework/impl/AsyncRdSet.kt [179:196]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - override fun assertBindingThread() { } override fun assertThreading() { } override fun onWireReceived(proto: IProtocol, buffer: AbstractBuffer, ctx: SerializationCtx, dispatchHelper: IRdWireableDispatchHelper) { synchronized(this) { super.onWireReceived(proto, buffer, ctx, object : IRdWireableDispatchHelper { override val rdId: RdId get() = dispatchHelper.rdId override val lifetime: Lifetime get() = dispatchHelper.lifetime override fun dispatch(scheduler: IScheduler?, action: () -> Unit) { dispatchHelper.dispatch(SynchronousScheduler, action) } }) - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -