@@ -8,7 +8,7 @@ var ReadableStreamBuffer = module.exports = function(opts) {
8
8
stream . Stream . call ( this ) ;
9
9
10
10
opts = opts || { } ;
11
- var frequency = opts . hasOwnProperty ( "frequency" ) ? opts . frequency : constants . DEFAULT_FREQUENCY ;
11
+ var frequency = opts . hasOwnProperty ( "frequency" ) ? opts . frequency : constants . DEFAULT_FREQUENCY ;
12
12
var chunkSize = opts . chunkSize || constants . DEFAULT_CHUNK_SIZE ;
13
13
var initialSize = opts . initialSize || constants . DEFAULT_INITIAL_SIZE ;
14
14
var incrementAmount = opts . incrementAmount || constants . DEFAULT_INCREMENT_AMOUNT ;
@@ -22,8 +22,8 @@ var ReadableStreamBuffer = module.exports = function(opts) {
22
22
23
23
var sendData = function ( ) {
24
24
if ( ! size ) {
25
- that . emit ( "end" ) ;
26
- return ;
25
+ that . emit ( "end" ) ;
26
+ return ;
27
27
}
28
28
29
29
var amount = Math . min ( chunkSize , size ) ;
@@ -77,26 +77,26 @@ var ReadableStreamBuffer = module.exports = function(opts) {
77
77
size += dataSizeInBytes ;
78
78
}
79
79
80
- if ( ! this . isPaused && ! frequency ) {
81
- while ( size > 0 ) {
82
- sendData ( ) ;
83
- }
84
- }
80
+ if ( ! this . isPaused && ! frequency ) {
81
+ while ( size > 0 ) {
82
+ sendData ( ) ;
83
+ }
84
+ }
85
85
} ;
86
86
87
87
this . pause = function ( ) {
88
- this . isPaused = true ;
89
- if ( sendData && sendData . interval ) {
90
- clearInterval ( sendData . interval ) ;
91
- delete sendData . interval ;
92
- }
88
+ this . isPaused = true ;
89
+ if ( sendData && sendData . interval ) {
90
+ clearInterval ( sendData . interval ) ;
91
+ delete sendData . interval ;
92
+ }
93
93
} ;
94
94
95
95
this . resume = function ( ) {
96
- this . isPaused = false ;
97
- if ( sendData && ! sendData . interval && frequency > 0 ) {
98
- sendData . interval = setInterval ( sendData , frequency ) ;
99
- }
96
+ this . isPaused = false ;
97
+ if ( sendData && ! sendData . interval && frequency > 0 ) {
98
+ sendData . interval = setInterval ( sendData , frequency ) ;
99
+ }
100
100
} ;
101
101
102
102
this . destroy = function ( ) {
0 commit comments