ref(GoogleCloudStreamingSession): share requestManager instance

...with parent.
jitsi · Jan 9, 2020 · b92d6f9 · b92d6f9
1 parent a1175a2
commit b92d6f9
Showing 1 changed file with 3 additions and 14 deletions.
diff --git a/src/main/java/org/jitsi/jigasi/transcription/GoogleCloudStreamingRecognitionSession.java b/src/main/java/org/jitsi/jigasi/transcription/GoogleCloudStreamingRecognitionSession.java
@@ -273,9 +273,7 @@ private ApiStreamObserver<StreamingRecognizeRequest> createObserver(
             // to get an unique ID
             ResponseApiStreamingObserver<StreamingRecognizeResponse>
                 responseObserver =
-                    new ResponseApiStreamingObserver<>(
-                            this,
-                            config.getLanguageCode());
+                    new ResponseApiStreamingObserver<>(config.getLanguageCode());
 
             // StreamingRecognitionConfig which will hold information
             // about the streaming session, including the RecognitionConfig
@@ -506,13 +504,6 @@ private class ResponseApiStreamingObserver
             <T extends StreamingRecognizeResponse>
             implements ApiStreamObserver<T>
     {
-        /**
-         * The manager which is used to send new audio requests. Should be
-         * notified when a final result comes in to be able to start a new
-         * session
-         */
-        private RequestApiStreamObserverManager requestManager;
-
         /**
          * The language of the speech being provided in the current session
          */
@@ -528,12 +519,10 @@ private class ResponseApiStreamingObserver
          * Create a ResponseApiStreamingObserver which listens for transcription
          * results
          *
-         * @param manager the manager of requests
+         * @param languageTag
          */
-        ResponseApiStreamingObserver(RequestApiStreamObserverManager manager,
-                                     String languageTag)
+        ResponseApiStreamingObserver(String languageTag)
         {
-            this.requestManager = manager;
             this.languageTag = languageTag;
 
             messageID = UUID.randomUUID();