@@ -33,21 +33,24 @@ class EditorClient extends DisposableController
3333
3434 Future <void > _initialize () async {
3535 autoDisposeStreamSubscription (
36- _dtd.onEvent ('Service' ).listen ((data) {
36+ _dtd.onEvent (CoreDtdServiceConstants .servicesStreamId ).listen ((data) {
3737 final kind = data.kind;
38- if (kind != 'ServiceRegistered' && kind != 'ServiceUnregistered' ) {
38+ if (kind != CoreDtdServiceConstants .serviceRegisteredKind &&
39+ kind != CoreDtdServiceConstants .serviceUnregisteredKind) {
3940 return ;
4041 }
4142
42- final service = data.data[' service' ] as String ? ;
43+ final service = data.data[DtdParameters . service] as String ? ;
4344 if (service == null ||
4445 (service != editorServiceName && service != lspServiceName)) {
4546 return ;
4647 }
4748
48- final isRegistered = kind == 'ServiceRegistered' ;
49- final method = data.data['method' ] as String ;
50- final capabilities = data.data['capabilities' ] as Map <String , Object ?>? ;
49+ final isRegistered =
50+ kind == CoreDtdServiceConstants .serviceRegisteredKind;
51+ final method = data.data[DtdParameters .method] as String ;
52+ final capabilities =
53+ data.data[DtdParameters .capabilities] as Map <String , Object ?>? ;
5154 final lspMethod = LspMethod .fromMethodName (method);
5255 if (lspMethod != null ) {
5356 lspMethod.isRegistered = isRegistered;
@@ -126,7 +129,7 @@ class EditorClient extends DisposableController
126129 }),
127130 );
128131 await [
129- _dtd.streamListen ('Service' ),
132+ _dtd.streamListen (CoreDtdServiceConstants .servicesStreamId ),
130133 _dtd.streamListen (editorStreamName).catchError ((_) {
131134 // Because we currently call streamListen in two places (here and
132135 // ThemeManager) this can fail. It doesn't matter if this happens,
0 commit comments