@@ -33,10 +33,10 @@ export class MonitorManager extends CoreClientAware {
33
33
disposedForUpload : [ ] ,
34
34
} ;
35
35
36
- private startMonitor_PendingRequests : {
36
+ private monitorServiceStartQueue : {
37
37
monitorID : string ;
38
- requestFor : [ Board , Port ] ;
39
- postStartCallback : ( status : Status ) => void ;
38
+ serviceStartParams : [ Board , Port ] ;
39
+ connectToClient : ( status : Status ) => void ;
40
40
} [ ] = [ ] ;
41
41
42
42
@inject ( MonitorServiceFactory )
@@ -66,15 +66,18 @@ export class MonitorManager extends CoreClientAware {
66
66
return false ;
67
67
}
68
68
69
- uploadIsInProgress ( ) : boolean {
69
+ private uploadIsInProgress ( ) : boolean {
70
70
return this . monitorIDsByUploadState . uploadInProgress . length > 0 ;
71
71
}
72
72
73
- addToMonitorIDsByUploadState ( state : UploadState , monitorID : string ) : void {
73
+ private addToMonitorIDsByUploadState (
74
+ state : UploadState ,
75
+ monitorID : string
76
+ ) : void {
74
77
this . monitorIDsByUploadState [ state ] . push ( monitorID ) ;
75
78
}
76
79
77
- removeFromMonitorIDsByUploadState (
80
+ private removeFromMonitorIDsByUploadState (
78
81
state : UploadState ,
79
82
monitorID : string
80
83
) : void {
@@ -83,7 +86,10 @@ export class MonitorManager extends CoreClientAware {
83
86
] . filter ( ( id ) => id !== monitorID ) ;
84
87
}
85
88
86
- monitorIDIsInUploadState ( state : UploadState , monitorID : string ) : boolean {
89
+ private monitorIDIsInUploadState (
90
+ state : UploadState ,
91
+ monitorID : string
92
+ ) : boolean {
87
93
return this . monitorIDsByUploadState [ state ] . includes ( monitorID ) ;
88
94
}
89
95
@@ -98,7 +104,7 @@ export class MonitorManager extends CoreClientAware {
98
104
async startMonitor (
99
105
board : Board ,
100
106
port : Port ,
101
- postStartCallback : ( status : Status ) => void
107
+ connectToClient : ( status : Status ) => void
102
108
) : Promise < void > {
103
109
const monitorID = this . monitorID ( board , port ) ;
104
110
@@ -108,22 +114,21 @@ export class MonitorManager extends CoreClientAware {
108
114
}
109
115
110
116
if ( this . uploadIsInProgress ( ) ) {
111
- this . startMonitor_PendingRequests =
112
- this . startMonitor_PendingRequests . filter (
113
- ( request ) => request . monitorID !== monitorID
114
- ) ;
117
+ this . monitorServiceStartQueue = this . monitorServiceStartQueue . filter (
118
+ ( request ) => request . monitorID !== monitorID
119
+ ) ;
115
120
116
- this . startMonitor_PendingRequests . push ( {
121
+ this . monitorServiceStartQueue . push ( {
117
122
monitorID,
118
- requestFor : [ board , port ] ,
119
- postStartCallback ,
123
+ serviceStartParams : [ board , port ] ,
124
+ connectToClient ,
120
125
} ) ;
121
126
122
127
return ;
123
128
}
124
129
125
130
const result = await monitor . start ( ) ;
126
- postStartCallback ( result ) ;
131
+ connectToClient ( result ) ;
127
132
}
128
133
129
134
/**
@@ -232,14 +237,14 @@ export class MonitorManager extends CoreClientAware {
232
237
// will include a request for our "upload port', most likely at index 0.
233
238
// We remove it, as this port was to be used exclusively for the upload
234
239
const queued = portDidChangeOnUpload
235
- ? this . startMonitor_PendingRequests . slice ( 1 )
236
- : this . startMonitor_PendingRequests ;
237
- this . startMonitor_PendingRequests = [ ] ;
240
+ ? this . monitorServiceStartQueue . slice ( 1 )
241
+ : this . monitorServiceStartQueue ;
242
+ this . monitorServiceStartQueue = [ ] ;
238
243
239
244
for ( const {
240
245
monitorID,
241
- requestFor : [ _ , port ] ,
242
- postStartCallback : onFinish ,
246
+ serviceStartParams : [ _ , port ] ,
247
+ connectToClient ,
243
248
} of queued ) {
244
249
const boardsState = await this . boardsService . getState ( ) ;
245
250
const boardIsStillOnPort = Object . keys ( boardsState )
@@ -254,7 +259,7 @@ export class MonitorManager extends CoreClientAware {
254
259
255
260
if ( monitorService ) {
256
261
const result = await monitorService . start ( ) ;
257
- onFinish ( result ) ;
262
+ connectToClient ( result ) ;
258
263
}
259
264
}
260
265
}
0 commit comments