chore(on_data): Error handling for received message

Author: ehdsouza

examples/speech_to_text_v1.py

@@ -50,9 +50,6 @@ def on_inactivity_timeout(self, error):
     def on_listening(self):
         print('Service is listening')
 
-    def on_transcription_complete(self):
-        print('Transcription completed')
-
     def on_hypothesis(self, hypothesis):
         print(hypothesis)
 

watson_developer_cloud/websocket/recognize_listener.py

@@ -143,7 +143,11 @@ def on_data(self, ws, message, message_type, fin):
         :param message_type: Message type which is either ABNF.OPCODE_TEXT or ABNF.OPCODE_BINARY
         :param fin: continue flag. If 0, the data continues.
         """
-        json_object = json.loads(message)
+
+        try:
+            json_object = json.loads(message)
+        except Exception:
+            self.on_error(ws, 'Unable to parse received message.')
 
         if 'error' in json_object:
             # Only call on_error() if a real error occurred. The STT service sends