Add speech async GAPIC.

Author: daspecster

docs/index.rst

@@ -176,8 +176,6 @@
   speech-usage
   Client <speech-client>
   speech-encoding
-  speech-metadata
-  speech-operation
   speech-sample
   speech-transcript
 

docs/speech-metadata.rst

@@ -70,9 +70,10 @@ See: `Speech Asynchronous Recognize`_
     >>> operation.complete
     True
     >>> for result in operation.results:
-    ...     print('=' * 20)
-    ...     print(result.transcript)
-    ...     print(result.confidence)
+    ...    print('=' * 20)
+    ...    for alternative in result.alternatives:
+    ...        print(alternative.transcript)
+    ...        print(alternative.confidence)
     ====================
     'how old is the Brooklyn Bridge'
     0.98267895

docs/speech-operation.rst

@@ -17,6 +17,10 @@
 from google.longrunning import operations_grpc
 
 from google.cloud.gapic.speech.v1beta1.speech_api import SpeechApi
+from google.cloud.grpc.speech.v1beta1.cloud_speech_pb2 import (
+    AsyncRecognizeMetadata)
+from google.cloud.grpc.speech.v1beta1.cloud_speech_pb2 import (
+    AsyncRecognizeResponse)
 from google.cloud.grpc.speech.v1beta1.cloud_speech_pb2 import SpeechContext
 from google.cloud.grpc.speech.v1beta1.cloud_speech_pb2 import RecognitionConfig
 from google.cloud.grpc.speech.v1beta1.cloud_speech_pb2 import RecognitionAudio
@@ -25,14 +29,18 @@
 from google.cloud.grpc.speech.v1beta1.cloud_speech_pb2 import (
     StreamingRecognizeRequest)
 
-
 from google.cloud._helpers import make_secure_stub
 from google.cloud.connection import DEFAULT_USER_AGENT
 from google.cloud.speech.transcript import Transcript
 from google.cloud.operation import Operation
+from google.cloud.operation import register_type
+
 
 OPERATIONS_API_HOST = 'speech.googleapis.com'
 
+register_type(AsyncRecognizeMetadata)
+register_type(AsyncRecognizeResponse)
+
 
 class GAPICSpeechAPI(object):
     """Manage calls through GAPIC wrappers to the Speech API."""
@@ -80,7 +88,8 @@ def async_recognize(self, sample, language_code=None,
                                and phrases. This can also be used to add new
                                words to the vocabulary of the recognizer.
 
-        :raises NotImplementedError: Always.
+        :rtype: :class:`~google.cloud.operation.Opeartion`
+        :returns: Instance of ``Operation`` to poll for results.
         """
         config = RecognitionConfig(
             encoding=sample.encoding, sample_rate=sample.sample_rate,
@@ -90,15 +99,15 @@ def async_recognize(self, sample, language_code=None,
 
         audio = RecognitionAudio(content=sample.content,
                                  uri=sample.source_uri)
+        api = self._gapic_api
+        response = api.async_recognize(config=config, audio=audio)
+
         self._client._operations_stub = make_secure_stub(
             self._client.connection.credentials,
             DEFAULT_USER_AGENT,
             operations_grpc.OperationsStub,
             OPERATIONS_API_HOST)
-
-        api = self._gapic_api
-        operation = api.sync_recognize(config=config, audio=audio)
-        return Operation.from_pb(operation, self._client)
+        return Operation.from_pb(response, self._client)
 
     def sync_recognize(self, sample, language_code=None, max_alternatives=None,
                        profanity_filter=None, speech_context=None):

docs/speech-usage.rst

@@ -23,7 +23,7 @@
 from google.cloud.environment_vars import DISABLE_GRPC
 from google.cloud.speech.connection import Connection
 from google.cloud.speech.encoding import Encoding
-from google.cloud.speech.operation import Operation
+from google.cloud.operation import Operation
 from google.cloud.speech.sample import Sample
 from google.cloud.speech.transcript import Transcript
 
@@ -287,7 +287,7 @@ def async_recognize(self, sample, language_code=None,
         api_response = self._connection.api_request(
             method='POST', path='speech:asyncrecognize', data=data)
 
-        return Operation.from_api_repr(self, api_response)
+        return Operation.from_dict(api_response, self)
 
     def sync_recognize(self, sample, language_code=None, max_alternatives=None,
                        profanity_filter=None, speech_context=None):