有偿求助，使用 Java 的 rsocket 上传文件

[shuang]

服务端是第三方的，我方需要按照接口文档上传文件。
1 、分片上传，实体为 Flux<DataBuffer>
2 、需要携带 header ，媒体类型为 application/json

需求比较简单，但同事之前一直做的 java web 开发，没接触过响应式的 rscoket 开发，网上相关的参考资料文档又少之又少，所以进展有点慢，报错也看不太懂，毫无头绪。例如：
readerIndex(1) + length(254) exceeds writerIndex(206): AbstractPooledDerivedByteBuf$PooledNonRetainedSlicedByteBuf(ridx: 1, widx: 206, cap: 206/206, unwrapped: PooledUnsafeDirectByteBuf(ridx: 322949, widx: 322958, cap: 524288))

希望寻求有过 rsocket 相关开发经验的人，帮忙看下代码哪里有问题。
解决后发微信红包作为报酬。

有意加 v(base64)：emhzaHUyMjIy

[guyeu]

有点抽象，传文件就把大文件分片成 DataBuffer 逐个上传就行了呀，rsocket 也不是基于 http 的，哪来的 header ，更别说文件还要传 application/json

[guyeu]

Flux 不是实体，Flux 是一个消息流，里面的元素才是数据

[shuang]

@guyeu 没办法，服务端是这么要求的，我猜这个 header 是不是放在 metadata 里