File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
rsocket-core/src/test/java/io/rsocket/resume Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 2
2
3
3
import io .netty .buffer .ByteBuf ;
4
4
import io .netty .buffer .Unpooled ;
5
+ import java .util .Arrays ;
5
6
import org .junit .Assert ;
6
7
import org .junit .jupiter .api .Test ;
7
8
import reactor .core .publisher .Flux ;
8
9
9
- import java .util .Arrays ;
10
-
11
10
public class InMemoryResumeStoreTest {
12
11
13
12
@ Test
@@ -81,13 +80,14 @@ void receiveImpliedPosition() {
81
80
private int size (ByteBuf ... byteBufs ) {
82
81
return Arrays .stream (byteBufs ).mapToInt (ByteBuf ::readableBytes ).sum ();
83
82
}
83
+
84
84
private static InMemoryResumableFramesStore inMemoryStore (int size ) {
85
85
return new InMemoryResumableFramesStore ("test" , size );
86
86
}
87
87
88
88
private static ByteBuf frameMock (int size ) {
89
89
byte [] bytes = new byte [size ];
90
- Arrays .fill (bytes ,(byte )7 );
90
+ Arrays .fill (bytes , (byte ) 7 );
91
91
return Unpooled .wrappedBuffer (bytes );
92
92
}
93
93
}
You can’t perform that action at this time.
0 commit comments