小编mic*_*cgn的帖子

我正在运行 Windows 10 专业版 1809。将 docker 图像推送到 docker.io 需要无限的时间（即使在几个小时后也无法完成）。在同一网络中的物理 Ubuntu 机器上，只需几秒钟即可完成相同的操作。

这似乎与我安装 docker 的方式无关。我尝试了 Docker for Windows（使用 Hyper-V）、Docker Machine（使用 VirtualBox），并且我自己在 VirtualBox 中安装了 Ubuntu+Docker。结果总是一样的。

我已经尝试禁用 Windows Defender，但没有任何改进。欢迎任何想法，因为我完全没有想法。

我有一个来自 RxJava 的 Single，并希望继续使用来自 Kotlin 的延迟协程。如何做到这一点？

fun convert(data: rx.Single<String>): kotlinx.coroutines.Deferred<String> = ...

我会对一些库（如果有的话？）以及自己做这件事感兴趣......到目前为止，我自己做了这个手工实现：

private fun waitForRxJavaResult(resultSingle: Single<String>): String? {
    var resultReceived = false
    var result: String? = null

    resultSingle.subscribe({
        result = it
        resultReceived = true
    }, {
        resultReceived = true
        if (!(it is NoSuchElementException))
            it.printStackTrace()
    })
    while (!resultReceived)
        Thread.sleep(20)

    return result
}

我使用 Glassfish 2 和容器管理的持久性和 Hibernate 3.2 作为持久性提供者。我的业务逻辑中有一些 finder 方法，它操作一些持久性实体，这些实体是通过EntityManager. 操作只是改变一个String属性（从集合中删除一个元素会导致相同的效果）。
我不叫像什么保存或坚持我的EntityManager。我只想将一些更改的实体返回给我的客户。

似乎当容器提交事务时，对我的实体的更改会自动保存。到目前为止，我完全错过了一些神奇的 Hibernate 或 Glassfish 行为吗？

在阅读了关于流的内容后,我现在尝试使用它们,并且已经通过简单的示例出现了第一个问题.我想实现一个非常简单的加密算法,它使用替换.有一些文本需要加密:

static List<Integer> text = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10,
        11, 12, 13, 14, 15, 16, 17, 18, 19, 20);

有一些密码:

private List<Integer> password = Arrays.asList(1, 5, 7, 3);

现在的想法是将密码值添加到文本值.结果应该是

1 + 1,2 + 5,3 + 7,4 + 3,5 + 1,6 + 5 ......

所以我必须从密码创建一个流,它从到达上面列表末尾的开头开始.这部分我已经设法做到了.

现在我不得不将2个流合并为1个流.任何想法,如何实现？

我正在使用Kafka流，并希望将Java的一些使用者偏移量重置为开始。 KafkaConsumer.seekToBeginning(...)听起来像是正确的事情，但是我使用Kafka Streams：

KafkaStreams streams = new KafkaStreams(builder, props);
...
streams.start();

我想根据我定义的具体流管道，这将在引擎盖下创建多个消费者。我可以访问那些吗？还是有其他方法以编程方式重置偏移量？

我想以面向流的方式处理 Android 上的传感器事件，最好使用 Kotlin 的协程。

对于传感器我知道如何实现回调SensorEventListener接口 public void onSensorChanged(SensorEvent event);

我怎样才能将数据发送到其中kotlinx.coroutines.channels.Channel？