File tree Expand file tree Collapse file tree 3 files changed +6
-0
lines changed
rsocket-core/src/main/java/io/rsocket Expand file tree Collapse file tree 3 files changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -61,8 +61,10 @@ public ConnectionSetupPayload retain(int increment) {
61
61
return this ;
62
62
}
63
63
64
+ @ Override
64
65
public abstract ConnectionSetupPayload touch ();
65
66
67
+ @ Override
66
68
public abstract ConnectionSetupPayload touch (Object hint );
67
69
68
70
private static final class DefaultConnectionSetupPayload extends ConnectionSetupPayload {
Original file line number Diff line number Diff line change @@ -44,6 +44,7 @@ class Tuple2ByteBuf extends AbstractTupleByteBuf {
44
44
this .freed = false ;
45
45
}
46
46
47
+ @ Override
47
48
long calculateRelativeIndex (int index ) {
48
49
checkIndex (index , 0 );
49
50
@@ -60,6 +61,7 @@ long calculateRelativeIndex(int index) {
60
61
return relativeIndex | mask ;
61
62
}
62
63
64
+ @ Override
63
65
ByteBuf getPart (int index ) {
64
66
long ri = calculateRelativeIndex (index );
65
67
switch ((int ) ((ri & MASK ) >>> 32L )) {
Original file line number Diff line number Diff line change @@ -57,6 +57,7 @@ public boolean isDirect() {
57
57
return one .isDirect () && two .isDirect () && three .isDirect ();
58
58
}
59
59
60
+ @ Override
60
61
public long calculateRelativeIndex (int index ) {
61
62
checkIndex (index , 0 );
62
63
long relativeIndex ;
@@ -75,6 +76,7 @@ public long calculateRelativeIndex(int index) {
75
76
return relativeIndex | mask ;
76
77
}
77
78
79
+ @ Override
78
80
public ByteBuf getPart (int index ) {
79
81
long ri = calculateRelativeIndex (index );
80
82
switch ((int ) ((ri & MASK ) >>> 32L )) {
You can’t perform that action at this time.
0 commit comments