пробовали)?
У меня теряются первые два Payload при RequestChannel
method -> ping(a: Flux<String>): Flux<String> = a
invoke -> ping(Flux.just("a", "b", "c", "d")) -> вернёт Flux {"c", "d"}
При этом фреймы с "a", "b" приходят, но теряются.
Может было у кого такое? Если да, как решали?
Похоже уже пофиксили: https://github.com/alibaba/alibaba-rsocket-broker/commit/5a09c7c51be016fdfa805c09b5a79417e401f1f8#diff-8ccd64dd8999d64b08e83c407b13d585
Обсуждают сегодня