ratpack.http.Request.getBodyStream() returns TransformablePublisher<? extends ByteBuf> which by default publishes/emits 8192 bytes of request body when requested by Subscriber using Subcription.request(1).
My question is:
1. how can I configure the number of bytes emitted by publisher
2. Is it possible to override publisher's publish/emit logic. if yes,how? My request consist of array of json objects and I want to publish 1 json object on each request of subscriber