Add possibility to cancel audio stream subscription

CHANGELOG.md

@@ -1,3 +1,6 @@
+## [1.2.1] - Add possibility to cancel audio stream subscription.
+* Add possibility to cancel audio stream subscription.
+
 ## [1.2.0] - Add SpeechContext support.
 * Add SpeechContext support.
 

lib/speech_to_text.dart

@@ -29,6 +29,10 @@ class SpeechToText {
   factory SpeechToText.viaServiceAccount(ServiceAccount account) =>
       SpeechToText._(account.callOptions);
 
+  /// Listen to audio stream.
+  /// Cancelled as soon as dispose is called.
+  StreamSubscription<List<int>> _audioStreamSubscription;
+
   /// Sends a [RecognizeRequest] request to the Google Speech Api.
   /// Requires a [RecognitionConfig] and an [RecognitionAudio].
   ///
@@ -63,13 +67,19 @@ class SpeechToText {
     request
         .add(StreamingRecognizeRequest()..streamingConfig = config.toConfig());
 
-    audioStream.listen((audio) {
+    _audioStreamSubscription = audioStream.listen((audio) {
       // Add audio content when stream changes.
       request.add(StreamingRecognizeRequest()..audioContent = audio);
-    }).onDone(() {
+    });
+
+    _audioStreamSubscription.onDone(() {
       // Close the request stream, if the audio stream is finished.
       request.close();
     });
     return client.streamingRecognize(request.stream);
   }
+
+  void dispose() {
+    _audioStreamSubscription?.cancel();
+  }
 }

lib/speech_to_text_beta.dart

@@ -30,6 +30,10 @@ class SpeechToTextBeta {
   factory SpeechToTextBeta.viaServiceAccount(ServiceAccount account) =>
       SpeechToTextBeta._(account.callOptions);
 
+  /// Listen to audio stream.
+  /// Cancelled as soon as dispose is called.
+  StreamSubscription<List<int>> _audioStreamSubscription;
+
   /// Sends a [RecognizeRequest] request to the Google Speech Api.
   /// Requires a [RecognitionConfig] and an [RecognitionAudio].
   ///
@@ -64,13 +68,19 @@ class SpeechToTextBeta {
     request
         .add(StreamingRecognizeRequest()..streamingConfig = config.toConfig());
 
-    audioStream.listen((audio) {
+    _audioStreamSubscription = audioStream.listen((audio) {
       // Add audio content when stream changes.
       request.add(StreamingRecognizeRequest()..audioContent = audio);
-    }).onDone(() {
+    });
+
+    _audioStreamSubscription.onDone(() {
       // Close the request stream, if the audio stream is finished.
       request.close();
     });
     return client.streamingRecognize(request.stream);
   }
+
+  void dispose() {
+    _audioStreamSubscription?.cancel();
+  }
 }

pubspec.yaml

@@ -1,6 +1,6 @@
 name: google_speech
 description: Flutter Plugin for the Google Cloud GRPC Speech-to-Text Api.
-version: 1.2.0
+version: 1.2.1
 homepage: https://github.com/felixjunghans/google_speech
 
 environment: