我使用的是SpringBoot2.0.2,我想插入 Flux 在mongodb的文档中使用spring数据的数组中使用 ReactiveMongoOperations . 例如(Kotlin代码):

val mongo : ReactiveMongoOperations = ...
data class Something(val data: String)
val flux = Flux.just(Something("A"), Something("B"))

mongo.upsert(query(where("_id").isEqualTo("myId")),
                        Update().push("myArray").each(flux),
                        "collection")

(注意这只是一个例子 flux 不是使用 Flux.just(..) 在实际代码中)。

虽然这样做不会产生我想要的结果:

{ "_id" : "myId", "myArray" : [ { "array" : [ { "data" : "A" }, { "data" : "B" } ], "_class" : "reactor.core.publisher.FluxArray" } ] }

我希望结果是:

{ "_id" : "myId", "myArray" : [ { "data" : "A" }, { "data" : "B" } ] }

也就是说,spring数据序列化了 通量 而不是 通量 本身。此示例生成正确的结果:

mongo.upsert(query(where("_id").isEqualTo("myId")),
                        Update().push("myArray").each(Something("A"), Something("B")),
                        "collection")

我怎样才能做到 无阻塞 ?