But you can do a little trick to make this work, i...

# rx

[edwardwongtl]

But you can do a little trick to make this work, instead of doing in onNext, do it in doOnNext and the before the stream ends, apply a `map`to transform it into MessageBody