File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
rsocket-core/src/test/java/io/rsocket/core Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -145,7 +145,7 @@ protected void hookOnSubscribe(Subscription subscription) {
145
145
ByteBuf f = sent .get (0 );
146
146
147
147
assertThat ("initial frame" , frameType (f ), is (REQUEST_STREAM ));
148
- assertThat ("initial request n" , RequestStreamFrameFlyweight .initialRequestN (f ), is (5 ));
148
+ assertThat ("initial request n" , RequestStreamFrameFlyweight .initialRequestN (f ), is (5L ));
149
149
assertThat ("should be released" , f .release (), is (true ));
150
150
rule .assertHasNoLeaks ();
151
151
}
@@ -332,7 +332,7 @@ protected void hookOnSubscribe(Subscription subscription) {}
332
332
333
333
Assertions .assertThat (FrameHeaderFlyweight .frameType (initialFrame )).isEqualTo (REQUEST_CHANNEL );
334
334
Assertions .assertThat (RequestChannelFrameFlyweight .initialRequestN (initialFrame ))
335
- .isEqualTo (Integer .MAX_VALUE );
335
+ .isEqualTo (Long .MAX_VALUE );
336
336
Assertions .assertThat (
337
337
RequestChannelFrameFlyweight .data (initialFrame ).toString (CharsetUtil .UTF_8 ))
338
338
.isEqualTo ("0" );
You can’t perform that action at this time.
0 commit comments