[speech-to-text] Added CountDownLatch to show interim results when

using web sockets #15

Author: germanattanasio

examples/java/com/ibm/watson/developer_cloud/speech_to_text/v1/RecognizeUsingWebSockets.java

@@ -2,6 +2,8 @@
 
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 
 import com.ibm.watson.developer_cloud.http.HttpMediaType;
 import com.ibm.watson.developer_cloud.speech_to_text.v1.model.SpeechResults;
@@ -11,22 +13,26 @@
  * Recognize using WebSockets a sample wav file and print the transcript into the console output.
  */
 public class RecognizeUsingWebSockets {
-  public static void main(String[] args) throws FileNotFoundException {
+  private static CountDownLatch lock = new CountDownLatch(1);
+
+  public static void main(String[] args) throws FileNotFoundException, InterruptedException {
     SpeechToText service = new SpeechToText();
     service.setUsernameAndPassword("<username>", "<password>");
 
     FileInputStream audio = new FileInputStream("src/test/resources/speech_to_text/sample1.wav");
 
-    RecognizeOptions options =
-        new RecognizeOptions().continuous(true).interimResults(true)
-            .contentType(HttpMediaType.AUDIO_WAV);
+    RecognizeOptions options = new RecognizeOptions();
+    options.continuous(true).interimResults(true).contentType(HttpMediaType.AUDIO_WAV);
 
     service.recognizeUsingWebSockets(audio, options, new BaseRecognizeDelegate() {
-
       @Override
       public void onMessage(SpeechResults speechResults) {
         System.out.println(speechResults);
+        if (speechResults.isFinal())
+          lock.countDown();
       }
     });
+
+    lock.await(20000, TimeUnit.MILLISECONDS);
   }
 }