@@ -25,7 +25,7 @@ describe('Stream', () => {
25
25
expect (
26
26
Buffer . compare (
27
27
data ,
28
- Buffer . from ( [ '00' , '01' , '00' , '01' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' ] )
28
+ Buffer . from ( [ 0x0 , 0x1 , 0x0 , 0x1 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 ] )
29
29
)
30
30
) . to . equal ( 0 ) ;
31
31
session . removeAllListeners ( 'data' ) ;
@@ -42,15 +42,15 @@ describe('Stream', () => {
42
42
expect (
43
43
Buffer . compare (
44
44
data ,
45
- Buffer . from ( [ '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '01' , 'ff' ] )
45
+ Buffer . from ( [ 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x1 , 0xff ] )
46
46
)
47
47
) . to . equal ( 0 ) ;
48
48
expect ( stream [ 'sendWindow' ] ) . to . equal ( 0 )
49
49
session . removeAllListeners ( 'data' ) ;
50
50
session . close ( ) ;
51
51
done ( ) ;
52
52
} ) ;
53
- stream . write ( Buffer . from ( [ 'ff' ] ) , ( ) => stream . close ( ) ) ;
53
+ stream . write ( Buffer . from ( [ 0xff ] ) , ( ) => stream . close ( ) ) ;
54
54
} ) ;
55
55
56
56
it ( 'waits for a window update if send window is empty' , ( done ) => {
@@ -61,7 +61,7 @@ describe('Stream', () => {
61
61
expect (
62
62
Buffer . compare (
63
63
data ,
64
- Buffer . from ( [ '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '01' , 'ff' ] )
64
+ Buffer . from ( [ 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x1 , 0xff ] )
65
65
)
66
66
) . to . equal ( 0 ) ;
67
67
expect ( stream [ 'sendWindow' ] ) . to . equal ( 0 )
@@ -70,7 +70,7 @@ describe('Stream', () => {
70
70
session . close ( ) ;
71
71
done ( ) ;
72
72
} ) ;
73
- stream . write ( Buffer . from ( [ 'ff' ] ) , ( ) => stream . close ( ) ) ;
73
+ stream . write ( Buffer . from ( [ 0xff ] ) , ( ) => stream . close ( ) ) ;
74
74
const hdr = new Header ( VERSION , TYPES . WindowUpdate , 0 , stream . ID ( ) , 1 ) ;
75
75
setTimeout ( ( ) => stream . incrSendWindow ( hdr ) , 50 )
76
76
} ) ;
@@ -82,13 +82,13 @@ describe('Stream', () => {
82
82
session . on ( 'data' , ( data ) => {
83
83
if ( data [ 1 ] === 0 ) { // packet is of type Data
84
84
numberOfDataPackets ++
85
- expect ( Buffer . compare ( data , Buffer . from ( [ '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '01' , 'ff' ] ) ) ) . to . equal ( 0 ) ;
85
+ expect ( Buffer . compare ( data , Buffer . from ( [ 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x1 , 0xff ] ) ) ) . to . equal ( 0 ) ;
86
86
expect ( stream [ 'sendWindow' ] ) . to . equal ( 0 )
87
87
const hdr = new Header ( VERSION , TYPES . WindowUpdate , 0 , stream . ID ( ) , 1 ) ;
88
88
stream . incrSendWindow ( hdr )
89
89
}
90
90
} ) ;
91
- stream . write ( Buffer . from ( [ 'ff' , 'ff' ] ) , ( ) => {
91
+ stream . write ( Buffer . from ( [ 0xff , 0xff ] ) , ( ) => {
92
92
expect ( numberOfDataPackets ) . to . equal ( 2 )
93
93
stream . close ( ) ;
94
94
session . removeAllListeners ( 'data' ) ;
@@ -104,7 +104,7 @@ describe('Stream', () => {
104
104
expect (
105
105
Buffer . compare (
106
106
data ,
107
- Buffer . from ( [ '00' , '01' , '00' , '04' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' ] )
107
+ Buffer . from ( [ 0x00 , 0x01 , 0x00 , 0x04 , 0x00 , 0x00 , 0x00 , 0x00 , 0x00 , 0x00 , 0x00 , 0x00 ] )
108
108
)
109
109
) . to . equal ( 0 ) ;
110
110
session . removeAllListeners ( 'data' ) ;
@@ -120,7 +120,7 @@ describe('Stream', () => {
120
120
expect (
121
121
Buffer . compare (
122
122
data ,
123
- Buffer . from ( [ '00' , '01' , '00' , '04' , '00' , '00' , '00' , '00' , '00' , '00' , '00' , '00' ] )
123
+ Buffer . from ( [ 0x00 , 0x01 , 0x00 , 0x4 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 , 0x0 ] )
124
124
)
125
125
) . to . equal ( 0 ) ;
126
126
session . removeAllListeners ( 'data' ) ;
0 commit comments