added a disable and enable method on the auto flusher and use that in e2e and unit tests where applicable

Author: ekjotmultani

packages/kinesis/aws_kinesis_datastreams/lib/src/impl/record_client.dart

@@ -168,6 +168,22 @@ class RecordClient {
     _scheduler.disable();
   }
 
+  /// Enables automatic flush operations.
+  ///
+  /// When enabled, the scheduler will trigger flush operations at the
+  /// configured interval. This does not affect manual flush() calls.
+  void enableAutoFlush() {
+    _scheduler.enable();
+  }
+
+  /// Disables automatic flush operations.
+  ///
+  /// When disabled, the scheduler will not trigger automatic flushes.
+  /// Manual flush() calls and record() calls still work normally.
+  void disableAutoFlush() {
+    _scheduler.disable();
+  }
+
   /// Closes the client and releases all resources.
   Future<void> close() async {
     _closed = true;

packages/kinesis/aws_kinesis_datastreams/lib/src/kinesis_data_streams.dart

@@ -215,6 +215,26 @@ class KinesisDataStreams {
     _recordClient.disable();
   }
 
+  /// Enables automatic flush operations.
+  ///
+  /// When enabled, records will be automatically flushed at the interval
+  /// specified in [KinesisDataStreamsOptions.flushStrategy].
+  ///
+  /// This does not affect manual [flush] calls or [record] operations.
+  void enableAutoFlush() {
+    _recordClient.enableAutoFlush();
+  }
+
+  /// Disables automatic flush operations.
+  ///
+  /// When disabled, records will not be automatically flushed.
+  /// You must call [flush] manually to send records to Kinesis.
+  ///
+  /// This does not affect manual [flush] calls or [record] operations.
+  void disableAutoFlush() {
+    _recordClient.disableAutoFlush();
+  }
+
   /// Closes the client and releases all resources.
   ///
   /// After closing:

packages/kinesis/aws_kinesis_datastreams/test/e2e/kinesis_e2e_test.dart

@@ -60,12 +60,12 @@ void main() {
       credentialsProvider: const AWSCredentialsProvider(credentials),
       storagePath: tempDir.path,
       options: const KinesisDataStreamsOptions(
-        flushStrategy: KinesisDataStreamsInterval(
-          interval: Duration(minutes: 5), // Disable auto-flush for tests
-        ),
         maxRetries: 3,
       ),
     );
+
+    // Disable auto-flush for controlled testing
+    client.disableAutoFlush();
   });
 
   tearDown(() async {

packages/kinesis/aws_kinesis_datastreams/test/record_client_test.dart

@@ -448,18 +448,28 @@ void main() {
         expect(client.isClosed, isTrue);
       });
 
-      test('ignores record calls after close', () async {
+      test('throws ClientClosedException on record after close', () async {
         await client.close();
 
-        await client.record(
-          KinesisRecord(
-            data: Uint8List.fromList([1]),
-            partitionKey: 'pk',
-            streamName: 'stream',
+        expect(
+          () => client.record(
+            KinesisRecord(
+              data: Uint8List.fromList([1]),
+              partitionKey: 'pk',
+              streamName: 'stream',
+            ),
           ),
+          throwsA(isA<ClientClosedException>()),
         );
+      });
 
-        // Can't check storage after close, but no exception should be thrown
+      test('throws ClientClosedException on flush after close', () async {
+        await client.close();
+
+        expect(
+          () => client.flush(),
+          throwsA(isA<ClientClosedException>()),
+        );
       });
     });
   });