rsocket-js - 如何使用相同的 requestChanel 接收消息并使用 rsocket-js 通过发射器发送消息

Question

我是 rsocket-js 的新手，并尝试使用相同的 chanel 接收消息并使用 rsocket-js（客户端）使用发射器发送消息。

socket.requestChannel(
    Flowable.just({
      data: data
   })
 ).subscribe({
    onComplete: () => { ... },
    onError: () =>  {},

    onNext: () => {  ...   },

    onSubscribe: () =>  { ... }
})