fixed Observe method

Author: ATILATosta

src/IBM.WatsonDeveloperCloud.SpeechToText/v1/SpeechToTextService.cs

@@ -415,9 +415,22 @@ public List<SpeechRecognitionEvent> ObserveResult(string sessionId, int? sequenc
                 if (interimResults)
                     request.WithArgument("interim_results", interimResults);
 
-                result =
-                    request.AsList<SpeechRecognitionEvent>()
+                var strResult =
+                    request.AsString()
                            .Result;
+                var serializer = new JsonSerializer();
+
+                using (var jsonReader = new JsonTextReader(new StringReader(strResult)))
+                {
+                    jsonReader.SupportMultipleContent = true;
+                    result = new List<SpeechRecognitionEvent>();
+
+                    while (jsonReader.Read())
+                    {
+                        var speechRecognitionEvent = serializer.Deserialize<SpeechRecognitionEvent>(jsonReader);
+                        result.Add(speechRecognitionEvent);
+                    }
+                }
             }
             catch (AggregateException ae)
             {

test/IBM.WatsonDeveloperCloud.SpeechToText.IntegrationTests/SpeechToTextServiceIntegrationTest.cs

@@ -223,7 +223,7 @@ public void t07_Recognize_WithSession_FormData_Sucess()
             Assert.IsNotNull(results.Results.First().Alternatives.First().Transcript);
         }
 
-        //[TestMethod]
+        [TestMethod]
         public void t08_ObserveResult_Success()
         {
             SpeechToTextService service =
@@ -244,18 +244,29 @@ public void t08_ObserveResult_Success()
                 PartContentType = audio.GetMediaTypeFromFile()
             };
 
-            var recognize =
-                service.RecognizeWithSession(session.SessionId, audio.GetMediaTypeFromFile(), metadata, audio, "chunked", modelName);
+            var taskObserveResult = Task.Factory.StartNew<List<SpeechRecognitionEvent>>(() =>
+            {
+                return service.ObserveResult(session.SessionId, interimResults: true);
+            });
 
-            var results =
-                service.ObserveResult(session.SessionId, interimResults: true);
+            taskObserveResult.ContinueWith((antecedent) =>
+            {
+                var results = antecedent.Result;
 
-            Assert.IsNotNull(results);
-            Assert.IsTrue(results.Count > 0);
-            Assert.IsNotNull(results.First().Results);
-            Assert.IsTrue(results.First().Results.Count > 0);
-            Assert.IsTrue(results.First().Results.First().Alternatives.Count > 0);
-            Assert.IsNotNull(results.First().Results.First().Alternatives.First().Transcript);
+                Assert.IsNotNull(results);
+                Assert.IsTrue(results.Count > 0);
+                Assert.IsNotNull(results.First().Results);
+                Assert.IsTrue(results.First().Results.Count > 0);
+                Assert.IsTrue(results.First().Results.First().Alternatives.Count > 0);
+                Assert.IsNotNull(results.First().Results.First().Alternatives.First().Transcript);
+            });
+
+            var taskRecognizeWithSession = Task.Factory.StartNew(() =>
+            {
+                service.RecognizeWithSession(session.SessionId, audio.GetMediaTypeFromFile(), metadata, audio, "chunked", modelName);
+            });
+
+            taskObserveResult.Wait();
         }
 
         [TestMethod]