File tree Expand file tree Collapse file tree 2 files changed +4
-5
lines changed
main/java/org/springframework/core/io/buffer
test/java/org/springframework/core/io/buffer Expand file tree Collapse file tree 2 files changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -519,15 +519,13 @@ default String toString(Charset charset) {
519
519
* A dedicated iterator type that ensures the lifecycle of iterated
520
520
* {@link ByteBuffer} elements. This iterator must be used in a
521
521
* try-with-resources clause or explicitly {@linkplain #close() closed}.
522
- *
523
522
* @see DataBuffer#readableByteBuffers()
524
523
* @see DataBuffer#writableByteBuffers()
525
524
*/
526
525
interface ByteBufferIterator extends Iterator <ByteBuffer >, Closeable {
527
526
528
527
@ Override
529
528
void close ();
530
-
531
529
}
532
530
533
531
}
Original file line number Diff line number Diff line change 65
65
class DataBufferUtilsTests extends AbstractDataBufferAllocatingTests {
66
66
67
67
private final Resource resource ;
68
+
68
69
private final Path tempFile ;
69
70
70
71
@@ -207,7 +208,7 @@ void readAsynchronousFileChannelCancel(DataBufferFactory bufferFactory) throws E
207
208
.verify ();
208
209
}
209
210
210
- @ ParameterizedDataBufferAllocatingTest // gh-22107
211
+ @ ParameterizedDataBufferAllocatingTest // gh-22107
211
212
void readAsynchronousFileChannelCancelWithoutDemand (DataBufferFactory bufferFactory ) throws Exception {
212
213
super .bufferFactory = bufferFactory ;
213
214
@@ -790,7 +791,6 @@ void SPR16070(DataBufferFactory bufferFactory) throws Exception {
790
791
.consumeNextWith (stringConsumer ("c" ))
791
792
.expectComplete ()
792
793
.verify (Duration .ofSeconds (5 ));
793
-
794
794
}
795
795
796
796
private Answer <Integer > putByte (int b ) {
@@ -833,7 +833,7 @@ void joinWithLimit(DataBufferFactory bufferFactory) {
833
833
.verifyError (DataBufferLimitException .class );
834
834
}
835
835
836
- @ Test // gh-26060
836
+ @ Test // gh-26060
837
837
void joinWithLimitDoesNotOverRelease () {
838
838
NettyDataBufferFactory bufferFactory = new NettyDataBufferFactory (PooledByteBufAllocator .DEFAULT );
839
839
byte [] bytes = "foo-bar-baz" .getBytes (StandardCharsets .UTF_8 );
@@ -1006,6 +1006,7 @@ void propagateContextPath(DataBufferFactory bufferFactory) throws IOException {
1006
1006
.verifyComplete ();
1007
1007
}
1008
1008
1009
+
1009
1010
private static class ZeroDemandSubscriber extends BaseSubscriber <DataBuffer > {
1010
1011
1011
1012
@ Override
You can’t perform that action at this time.
0 commit comments