Fix lint errors

Author: dnys1

.github/workflows/celest_cli.e2e.yaml

@@ -29,9 +29,9 @@ jobs:
       fail-fast: false
       matrix:
         os:
-          - ubuntu-latest
+          - ubuntu-large
           - macos-latest
-          - windows-latest
+          # - windows-latest
     runs-on: ${{ matrix.os }}
     timeout-minutes: 45
     steps:

.github/workflows/celest_cli.yaml

@@ -31,7 +31,7 @@ jobs:
         os:
           - ubuntu-large
           - macos-latest-xlarge
-          - windows-large
+          # - windows-large
     runs-on: ${{ matrix.os }}
     timeout-minutes: 45
     steps:

packages/celest_cloud/CHANGELOG.md

@@ -1,3 +1,7 @@
+# NEXT
+
+- chore: Fix lint errors
+
 # 0.1.9
 
 - chore: Bump Dart SDK constraint to `^3.7.0`

packages/celest_cloud/lib/src/cloud/base/base_service.dart

@@ -37,23 +37,24 @@ abstract mixin class BaseService {
   }
 
   @protected
-  Stream<OperationState<Metadata, Response>> streamOperation<
-    Metadata extends GeneratedMessage,
-    Response extends GeneratedMessage
+  Stream<OperationState<TMetadata, TResponse>> streamOperation<
+    TMetadata extends GeneratedMessage,
+    TResponse extends GeneratedMessage
   >(
     String name, {
     required Operation operation,
     required OperationsProtocol operations,
-    required Metadata metadata,
-    required Response response,
+    required TMetadata metadata,
+    required TResponse response,
     Logger? logger,
   }) async* {
-    final Stream<OperationState<Metadata, Response>> stream = operation.stream(
-      operations: operations,
-      metadata: metadata,
-      response: response,
-      logger: logger,
-    );
+    final Stream<OperationState<TMetadata, TResponse>> stream = operation
+        .stream(
+          operations: operations,
+          metadata: metadata,
+          response: response,
+          logger: logger,
+        );
     try {
       await for (final state in stream) {
         logger?.fine('[$name.${operation.name}] Operation state:\n$state');

packages/celest_cloud/lib/src/util/operations.dart

@@ -30,49 +30,51 @@ extension WaitForOperation on Operation {
     return operation.response.unpackInto(response);
   }
 
-  Stream<OperationState<Metadata, Response>>
-  stream<Metadata extends GeneratedMessage, Response extends GeneratedMessage>({
+  Stream<OperationState<TMetadata, TResponse>> stream<
+    TMetadata extends GeneratedMessage,
+    TResponse extends GeneratedMessage
+  >({
     required OperationsProtocol operations,
-    required Metadata metadata,
-    required Response response,
+    required TMetadata metadata,
+    required TResponse response,
     Logger? logger,
   }) {
     if (done) {
       return Stream.value(
-        state<Metadata, Response>(metadata: metadata, response: response),
+        state<TMetadata, TResponse>(metadata: metadata, response: response),
       );
     }
     return OperationWaiter(
       this,
       protocol: operations,
       logger: logger,
     ).stream.map((operation) {
-      return operation.state<Metadata, Response>(
+      return operation.state<TMetadata, TResponse>(
         metadata: metadata,
         response: response,
       );
     });
   }
 
-  OperationState<Metadata, Response> state<
-    Metadata extends GeneratedMessage,
-    Response extends GeneratedMessage
-  >({required Metadata metadata, required Response response}) {
+  OperationState<TMetadata, TResponse> state<
+    TMetadata extends GeneratedMessage,
+    TResponse extends GeneratedMessage
+  >({required TMetadata metadata, required TResponse response}) {
     if (done) {
       if (hasError()) {
-        return OperationFailure<Metadata, Response>(
+        return OperationFailure<TMetadata, TResponse>(
           id: name,
           metadata: hasMetadata() ? metadata.unpack(this.metadata) : metadata,
           error: error.grpcError,
         );
       }
-      return OperationSuccess<Metadata, Response>(
+      return OperationSuccess<TMetadata, TResponse>(
         id: name,
         metadata: hasMetadata() ? metadata.unpack(this.metadata) : metadata,
         response: response.unpack(ensureResponse()),
       );
     }
-    return OperationInProgress<Metadata, Response>(
+    return OperationInProgress<TMetadata, TResponse>(
       id: name,
       metadata: hasMetadata() ? metadata.unpack(this.metadata) : metadata,
     );
@@ -92,24 +94,24 @@ extension<T extends GeneratedMessage> on T {
 }
 
 sealed class OperationState<
-  Metadata extends GeneratedMessage,
-  Response extends GeneratedMessage
+  TMetadata extends GeneratedMessage,
+  TResponse extends GeneratedMessage
 > {
   OperationState({required this.id, required this.metadata});
 
   final String id;
-  final Metadata metadata;
+  final TMetadata metadata;
 
   bool get done => false;
-  Response? get response => null;
+  TResponse? get response => null;
   GrpcError? get error => null;
 }
 
 final class OperationInProgress<
-  Metadata extends GeneratedMessage,
-  Response extends GeneratedMessage
+  TMetadata extends GeneratedMessage,
+  TResponse extends GeneratedMessage
 >
-    extends OperationState<Metadata, Response> {
+    extends OperationState<TMetadata, TResponse> {
   OperationInProgress({required super.id, required super.metadata});
 
   @override
@@ -122,10 +124,10 @@ final class OperationInProgress<
 }
 
 final class OperationSuccess<
-  Metadata extends GeneratedMessage,
-  Response extends GeneratedMessage
+  TMetadata extends GeneratedMessage,
+  TResponse extends GeneratedMessage
 >
-    extends OperationState<Metadata, Response> {
+    extends OperationState<TMetadata, TResponse> {
   OperationSuccess({
     required super.id,
     required super.metadata,
@@ -136,7 +138,7 @@ final class OperationSuccess<
   bool get done => true;
 
   @override
-  final Response response;
+  final TResponse response;
 
   @override
   String toString() {
@@ -149,10 +151,10 @@ final class OperationSuccess<
 }
 
 final class OperationCancelled<
-  Metadata extends GeneratedMessage,
-  Response extends GeneratedMessage
+  TMetadata extends GeneratedMessage,
+  TResponse extends GeneratedMessage
 >
-    extends OperationState<Metadata, Response> {
+    extends OperationState<TMetadata, TResponse> {
   OperationCancelled({required super.id, required super.metadata});
 
   @override
@@ -168,10 +170,10 @@ final class OperationCancelled<
 }
 
 final class OperationFailure<
-  Metadata extends GeneratedMessage,
-  Response extends GeneratedMessage
+  TMetadata extends GeneratedMessage,
+  TResponse extends GeneratedMessage
 >
-    extends OperationState<Metadata, Response> {
+    extends OperationState<TMetadata, TResponse> {
   OperationFailure({
     required super.id,
     required super.metadata,