File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
packages/rsocket-core/src Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ import {
37
37
} from "./Frames" ;
38
38
39
39
export const FLAGS_MASK = 0x3ff ; // low 10 bits
40
- export const FRAME_TYPE_OFFFSET = 10 ; // frame type is offset 10 bytes within the uint16 containing type + flags
40
+ export const FRAME_TYPE_OFFSET = 10 ; // frame type is offset 10 bytes within the uint16 containing type + flags
41
41
42
42
export const MAX_CODE = 0x7fffffff ; // uint31
43
43
export const MAX_KEEPALIVE = 0x7fffffff ; // uint31
@@ -176,7 +176,7 @@ export function deserializeFrame(buffer: Buffer): Frame {
176
176
// );
177
177
const typeAndFlags = buffer . readUInt16BE ( offset ) ;
178
178
offset += 2 ;
179
- const type = typeAndFlags >>> FRAME_TYPE_OFFFSET ; // keep highest 6 bits
179
+ const type = typeAndFlags >>> FRAME_TYPE_OFFSET ; // keep highest 6 bits
180
180
const flags = typeAndFlags & FLAGS_MASK ; // keep lowest 10 bits
181
181
switch ( type ) {
182
182
case FrameTypes . SETUP :
@@ -1096,7 +1096,7 @@ function writeHeader(frame: Frame, buffer: Buffer): number {
1096
1096
const offset = buffer . writeInt32BE ( frame . streamId , 0 ) ;
1097
1097
// shift frame to high 6 bits, extract lowest 10 bits from flags
1098
1098
return buffer . writeUInt16BE (
1099
- ( frame . type << FRAME_TYPE_OFFFSET ) | ( frame . flags & FLAGS_MASK ) ,
1099
+ ( frame . type << FRAME_TYPE_OFFSET ) | ( frame . flags & FLAGS_MASK ) ,
1100
1100
offset
1101
1101
) ;
1102
1102
}
You can’t perform that action at this time.
0 commit comments