added async samples

puneithk · puneithk · commit f221210afac4 · 2016-07-06T11:41:37.000-07:00
Author: puneith &lt;puneith@google.com&gt;
diff --git a/speech/grpc/README.md b/speech/grpc/README.md
@@ -73,9 +73,9 @@ note that the audio file must be in RAW format.  You can use `sox`
 (available, e.g. via [http://sox.sourceforge.net/](http://sox.sourceforge.net/)
 or [homebrew](http://brew.sh/)) to convert audio files to raw format.
 
-### Run the non-streaming client
+### Run the sync client
 
-You can run the batch client like this:
+You can run the sync client like this:
 
 ```sh
 $ bin/speech-sample-sync.sh --host=speech.googleapis.com --port=443 \
@@ -89,6 +89,21 @@ $ bin/speech-sample-sync.sh --host=speech.googleapis.com --port=443 \
 --uri=resources/audio.raw --sampling=16000
 ```
 
+### Run the async client
+
+You can run the async client like this:
+
+```sh
+bin/speech-sample-async.sh --host=speech.googleapis.com --port=443 \
+--uri=<audio file uri> --sampling=<sample rate>
+```
+
+Try a streaming rate of 16000 and the included sample audio file, as follows:
+```sh
+$ bin/speech-sample-async.sh --host=speech.googleapis.com --port=443 \
+--uri=resources/audio.raw --sampling=16000
+```
+
 ### Run the streaming client
 
 You can run the streaming client as follows:
diff --git a/speech/grpc/bin/speech-sample-async.sh b/speech/grpc/bin/speech-sample-async.sh
@@ -0,0 +1,18 @@
+#!/bin/bash
+# Copyright 2016 Google Inc. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+SRC_DIR=$(cd "$(dirname "$0")/.."; pwd)
+java -cp ${SRC_DIR}/target/grpc-sample-1.0-jar-with-dependencies.jar \
+    com.google.cloud.speech.grpc.demos.AsyncRecognizeClient "$@"
diff --git a/speech/grpc/src/main/java/com/google/cloud/speech/grpc/demos/AsyncRecognizeClient.java b/speech/grpc/src/main/java/com/google/cloud/speech/grpc/demos/AsyncRecognizeClient.java
@@ -34,7 +34,9 @@
 import com.google.cloud.speech.v1beta1.AsyncRecognizeResponse;
 import com.google.protobuf.TextFormat;
 
-import google.longrunning.Operation;
+import com.google.longrunning.GetOperationRequest;
+import com.google.longrunning.Operation;
+import com.google.longrunning.OperationsGrpc;
 
 import io.grpc.ManagedChannel;
 import io.grpc.StatusRuntimeException;
@@ -76,6 +78,7 @@ public class AsyncRecognizeClient {
 
   private final ManagedChannel channel;
   private final SpeechGrpc.SpeechBlockingStub stub;
+  private final OperationsGrpc.OperationsBlockingStub op;
 
   /**
    * Construct client connecting to Cloud Speech server at {@code host:port}.
@@ -94,6 +97,8 @@ public AsyncRecognizeClient(String host, int port, URI input, int samplingRate)
         .intercept(new ClientAuthInterceptor(creds, Executors.newSingleThreadExecutor()))
         .build();
     stub = SpeechGrpc.newBlockingStub(channel);
+    op = OperationsGrpc.newBlockingStub(channel);
+
     logger.info("Created stub for " + host + ":" + port);
   }
 
@@ -124,23 +129,38 @@ public void recognize() {
         .setAudio(audio)
         .build();
 
-    Operation operation;
+    Operation operation, status;
     try {
       operation = stub.asyncRecognize(request);
 
       //Print the long running operation handle
-      System.out.println(operation);
+      logger.log(Level.INFO, String.format("Operation handle: %s, URI: %s", operation.getName(),
+        input.toString()));
     } catch (StatusRuntimeException e) {
       logger.log(Level.WARNING, "RPC failed: {0}", e.getStatus());
       return;
     }
 
-    while(operation.hasDone()) {
-        System.out.println(operation);
-        //Sleep for 1 s
-        Thread.sleep(1000);
+    while(true) {
+      try {
+        logger.log(Level.INFO, "Waiting 2s for operation, {0} processing...", operation.getName());
+        Thread.sleep(2000);
+        GetOperationRequest operationReq = GetOperationRequest.newBuilder()
+            .setName(operation.getName())
+            .build();
+        status = op.getOperation(
+            GetOperationRequest.newBuilder()
+                .setName(operation.getName())
+                .build()
+                );
+
+        if(status.getDone()) break;
+      }catch(Exception ex) {
+        logger.log(Level.WARNING, ex.getMessage());
+      }
     }
-    //logger.info("Received response: " +  TextFormat.printToString(response));
+
+    logger.info("Received response: " + status.getResponse());
   }
 
   public static void main(String[] args) throws Exception {
