File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -35,7 +35,7 @@ class RequestQueue {
3535 * Enqueue a new request.
3636 */
3737 public enqueue ( request : Request ) {
38- this . _logger . appendLine ( `Enqueue request for ${ request . command } .` ) ;
38+ this . _logger . appendLine ( `Enqueue ${ this . _name } request for ${ request . command } .` ) ;
3939 this . _pending . push ( request ) ;
4040 }
4141
@@ -47,7 +47,7 @@ class RequestQueue {
4747
4848 if ( request ) {
4949 this . _waiting . delete ( id ) ;
50- this . _logger . appendLine ( `Dequeue request for ${ request . command } .` ) ;
50+ this . _logger . appendLine ( `Dequeue ${ this . _name } request for ${ request . command } ( ${ id } ) .` ) ;
5151 }
5252
5353 return request ;
@@ -87,6 +87,9 @@ class RequestQueue {
8787 return ;
8888 }
8989
90+ this . _logger . appendLine ( `Processing ${ this . _name } queue` ) ;
91+ this . _logger . increaseIndent ( ) ;
92+
9093 const slots = this . _maxSize - this . _waiting . size ;
9194
9295 for ( let i = 0 ; i < slots && this . _pending . length > 0 ; i ++ ) {
@@ -97,9 +100,11 @@ class RequestQueue {
97100 this . _waiting . set ( id , item ) ;
98101
99102 if ( this . isFull ( ) ) {
100- return ;
103+ break ;
101104 }
102105 }
106+
107+ this . _logger . decreaseIndent ( ) ;
103108 }
104109}
105110
You can’t perform that action at this time.
0 commit comments