I want to use bufferUntil with a custom List<DataBuffer> to keep track and enforces a limit on the total number of bytes buffered. I could use something more custom for this, like handle but then I lose the ability to release cached items via doOnDiscard. As far as I can see there is currently no way to do "buffer until" with a custom custom Collection like it is possible with the collect operator.
I want to use
bufferUntilwith a customList<DataBuffer>to keep track and enforces a limit on the total number of bytes buffered. I could use something more custom for this, likehandlebut then I lose the ability to release cached items viadoOnDiscard. As far as I can see there is currently no way to do "buffer until" with a custom customCollectionlike it is possible with thecollectoperator.