spring-framework / org.springframework.core.io.buffer / DataBufferUtils / skipUntilByteCount

skipUntilByteCount

open static fun skipUntilByteCount(publisher: Publisher<DataBuffer>, maxByteCount: Long): Flux<DataBuffer>

Skip buffers from the given Publisher until the total byte count reaches the given maximum byte count, or until the publisher is complete.

Parameters

publisher - the publisher to filter

maxByteCount - the maximum byte count

Return
a flux with the remaining part of the given publisher