时间戳

首页 > 解决方案 > Star 投影集合中的特定 KClass

generics - Star 投影集合中的特定 KClass

问题描述

我正在尝试构建一个外部模块可以注册的同步类，但我无法使泛型部分工作。

外部模块将SynchronizationBundle<SynchronizableType>在 a 上注册Synchronizator，然后应该处理同步。

interface Synchronizable<T : Synchronizable<T>>

object SynchronizationBundles {
    val bundles: MutableMap<KClass<*>, SynchronizableBundle<*>> = mutableMapOf()

    fun <T : Synchronizable<T>> register(kClass: KClass<T>, bundle: SynchronizableBundle<T>) {
        bundles[kClass] = bundle
    }

    @Suppress("UNCHECKED_CAST")
    operator fun <T: Synchronizable<T>> get(kClass: KClass<T>) : SynchronizableBundle<T> {
        return bundles[kClass] as? SynchronizableBundle<T> ?: throw IllegalArgumentException("No bundle for ${kClass.simpleName}")
    }
}

例如，在同步操作中，它应该遍历已注册的捆绑包并能够使用Synchronizable<T>. 前面的伪代码

fun synchronize() {
    bundles.forEach { bundleEntry ->
        val bundle = bundles[bundleEntry.key]
        val synchronizables = bundle.api.get()

        remoteSynchronizables.forEach { remoteSynchronizable ->
            val localSynchronizable = bundle.datastore.getByPlatformId(remoteSynchronizable.platformId)

            val synchronizableToInsert = bundle.conflictStrategy.resolve(localSynchronizable, remoteSynchronizable)

            synchronizableToInsert?.let {
                bundle.datastore.insert(it.withUploadStatus(UploadStatus.COMPLETED))
            }
        }
    }
}

问题是val bundle = bundles[bundleEntry.key]返回 a SynchronizableBundle<*>，所以我不能调用.conflictStrategy.resolve，因为它需要 aSynchronizable<T>

例如，这是ConflictStrategy定义。Api 和 Datastore 遵循相同的模式

interface ConflictStrategy<T : Synchronizable<T>>

这甚至可能吗？我敢肯定我不是第一个尝试这种方法的人。

如果我能以某种方式调用val bundle = bundles[MySynchronizable::class]我会得到一个SynchronizableBundle<MySynchronizable>，但我没有成功地做到这一点。此外，可以使用的类型Synchronizator将在外部模块中，所以我什至不知道构建特定的KClass是否可行。

使用高阶函数可能会让我的生活更轻松，而且这个 Synchronizator 可能与类型无关，但我没有尝试过。

谢谢！

标签： genericskotlin

解决方案

在下文中，我稍微简化了代码以演示如何从外部使用此捆绑管理器：

object Bundles{
    private val bundles: MutableMap<KClass<*>, Bundle<*>> = mutableMapOf()

    fun <T>  register(c: KClass<T>, b: Bundle<T>){
        bundles[c]= b
    }

    operator fun <T> get(kClass: KClass<T>) : Bundle<T> {
        return bundles[kClass] as? Bundle<T> ?: throw IllegalArgumentException("No bundle for ${kClass.simpleName}")
    }

}

fun main(args: Array<String>) {
    Bundles.register(String::class, Bundle())
    Bundles.register(Int::class, Bundle())
    Bundles.register(Number::class, Bundle())

    val stringBundle = Bundles[String::class]
    val intBundle = Bundles[Int::class]
    val numBundle = Bundles[Number::class]
}

你已经注意到这行得通。现在，您正在尝试循环bundles内部的SynchronizationBundles. 此时您无法知道已添加了什么bundles，因此无法从中获取具体实例。恐怕您必须研究其他方法。

推荐阅读