Skip to content

Commit 3d0d4ea

Browse files
committed
addressing analyzer issues
1 parent 8bce65a commit 3d0d4ea

File tree

4 files changed

+16
-35
lines changed

4 files changed

+16
-35
lines changed

dwds/lib/src/dwds_vm_client.dart

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@ class DwdsVmClient implements IDwdsVmClient {
6868

6969
DwdsVmClient(this.client, this._requestController, this._responseController);
7070

71+
@override
7172
Future<void> close() =>
7273
_closed ??= () async {
7374
await _requestController.close();

dwds/lib/src/services/chrome_proxy_service.dart

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ class ChromeProxyService extends ProxyService {
9494
bool terminatingIsolates = false;
9595

9696
ChromeProxyService._(
97-
VM vm,
97+
super.vm,
9898
this.root,
9999
this._assetReader,
100100
this.remoteDebugger,
@@ -103,7 +103,7 @@ class ChromeProxyService extends ProxyService {
103103
this._skipLists,
104104
this.executionContext,
105105
this._compiler,
106-
) : super(vm) {
106+
) {
107107
final debugger = Debugger.create(
108108
remoteDebugger,
109109
streamNotify,
@@ -1370,6 +1370,7 @@ class ChromeProxyService extends ProxyService {
13701370

13711371
/// Parses the [BatchedDebugEvents] and emits corresponding Dart VM Service
13721372
/// protocol [Event]s.
1373+
@override
13731374
void parseBatchedDebugEvents(BatchedDebugEvents debugEvents) {
13741375
for (final debugEvent in debugEvents.events) {
13751376
parseDebugEvent(debugEvent);

dwds/lib/src/services/proxy_service.dart

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,8 @@ abstract class ProxyService implements VmServiceInterface {
2828
final vm_service.VM _vm;
2929

3030
/// Signals when isolate is initialized.
31-
Future<void> get isInitialized => _initializedCompleter.future;
32-
Completer<void> _initializedCompleter = Completer<void>();
31+
Future<void> get isInitialized => initializedCompleter.future;
32+
Completer<void> initializedCompleter = Completer<void>();
3333

3434
/// The flags that can be set at runtime via [setFlag] and their respective
3535
/// values.
@@ -67,9 +67,6 @@ abstract class ProxyService implements VmServiceInterface {
6767
StreamController<String> get resumeAfterRestartEventsController =>
6868
_resumeAfterRestartEventsController;
6969
Map<String, bool> get currentVmServiceFlags => _currentVmServiceFlags;
70-
Completer<void> get initializedCompleter => _initializedCompleter;
71-
set initializedCompleter(Completer<void> completer) =>
72-
_initializedCompleter = completer;
7370

7471
ProxyService(this._vm);
7572

dwds/lib/src/services/web_socket_proxy_service.dart

Lines changed: 10 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ class _ServiceExtensionTracker {
7575
responses.add(response);
7676
}
7777

78-
bool get allSuccessful => responses.every((r) => r.success == true);
78+
bool get allSuccessful => responses.every((r) => r.success);
7979

8080
void dispose() {
8181
timeoutTimer.cancel();
@@ -659,9 +659,7 @@ class WebSocketProxyService extends ProxyService {
659659
if (tracker.allSuccessful) {
660660
tracker.completer.complete(response);
661661
} else {
662-
final failedResponses = tracker.responses.where(
663-
(r) => r.success != true,
664-
);
662+
final failedResponses = tracker.responses.where((r) => !r.success);
665663
final errorMessages = failedResponses
666664
.map((r) => r.errorMessage ?? 'Unknown error')
667665
.join('; ');
@@ -696,6 +694,7 @@ class WebSocketProxyService extends ProxyService {
696694

697695
/// Parses the [BatchedDebugEvents] and emits corresponding Dart VM Service
698696
/// protocol [Event]s.
697+
@override
699698
void parseBatchedDebugEvents(BatchedDebugEvents debugEvents) {
700699
for (final debugEvent in debugEvents.events) {
701700
parseDebugEvent(debugEvent);
@@ -770,7 +769,7 @@ class WebSocketProxyService extends ProxyService {
770769
);
771770

772771
Future<UriList> _lookupResolvedPackageUris(
773-
String isolateId,
772+
String _,
774773
List<String> uris,
775774
) async {
776775
await isInitialized;
@@ -782,7 +781,7 @@ class WebSocketProxyService extends ProxyService {
782781
Future<Success> pause(String isolateId) =>
783782
wrapInErrorHandlerAsync('pause', () => _pause(isolateId));
784783

785-
Future<Success> _pause(String isolateId) async {
784+
Future<Success> _pause(String _) async {
786785
// Create a pause event and store it
787786
if (_isolateRef != null) {
788787
final pauseEvent = vm_service.Event(
@@ -800,16 +799,9 @@ class WebSocketProxyService extends ProxyService {
800799
/// Resumes execution of the isolate.
801800
@override
802801
Future<Success> resume(String isolateId, {String? step, int? frameIndex}) =>
803-
wrapInErrorHandlerAsync(
804-
'resume',
805-
() => _resume(isolateId, step: step, frameIndex: frameIndex),
806-
);
802+
wrapInErrorHandlerAsync('resume', () => _resume(isolateId));
807803

808-
Future<Success> _resume(
809-
String isolateId, {
810-
String? step,
811-
int? frameIndex,
812-
}) async {
804+
Future<Success> _resume(String isolateId) async {
813805
if (hasPendingRestart && !resumeAfterRestartEventsController.isClosed) {
814806
resumeAfterRestartEventsController.add(isolateId);
815807
} else {
@@ -848,10 +840,7 @@ class WebSocketProxyService extends ProxyService {
848840
() => _lookupPackageUris(isolateId, uris),
849841
);
850842

851-
Future<UriList> _lookupPackageUris(
852-
String isolateId,
853-
List<String> uris,
854-
) async {
843+
Future<UriList> _lookupPackageUris(String _, List<String> uris) async {
855844
await isInitialized;
856845
return UriList(uris: uris.map(DartUri.toPackageUri).toList());
857846
}
@@ -883,16 +872,9 @@ class WebSocketProxyService extends ProxyService {
883872
String isolateId, {
884873
String? idZoneId,
885874
int? limit,
886-
}) => wrapInErrorHandlerAsync(
887-
'getStack',
888-
() => _getStack(isolateId, idZoneId: idZoneId, limit: limit),
889-
);
875+
}) => wrapInErrorHandlerAsync('getStack', () => _getStack(isolateId));
890876

891-
Future<vm_service.Stack> _getStack(
892-
String isolateId, {
893-
String? idZoneId,
894-
int? limit,
895-
}) async {
877+
Future<vm_service.Stack> _getStack(String isolateId) async {
896878
if (!_isIsolateRunning || _isolateRef == null) {
897879
throw vm_service.RPCError(
898880
'getStack',

0 commit comments

Comments
 (0)