Create an internal method for both client_output and client_output_async

Author: lidizheng

gapic/schema/wrappers.py

@@ -538,63 +538,13 @@ def __getattr__(self, name):
 
     @utils.cached_property
     def client_output(self):
-        """Return the output from the client layer.
-
-        This takes into account transformations made by the outer GAPIC
-        client to transform the output from the transport.
-
-        Returns:
-            Union[~.MessageType, ~.PythonType]:
-                A description of the return type.
-        """
-        # Void messages ultimately return None.
-        if self.void:
-            return PrimitiveType.build(None)
-
-        # If this method is an LRO, return a PythonType instance representing
-        # that.
-        if self.lro:
-            return PythonType(meta=metadata.Metadata(
-                address=metadata.Address(
-                    name='Operation',
-                    module='operation',
-                    package=('google', 'api_core'),
-                    collisions=self.lro.response_type.ident.collisions,
-                ),
-                documentation=utils.doc(
-                    'An object representing a long-running operation. \n\n'
-                    'The result type for the operation will be '
-                    ':class:`{ident}`: {doc}'.format(
-                        doc=self.lro.response_type.meta.doc,
-                        ident=self.lro.response_type.ident.sphinx,
-                    ),
-                ),
-            ))
-
-        # If this method is paginated, return that method's pager class.
-        if self.paged_result_field:
-            return PythonType(meta=metadata.Metadata(
-                address=metadata.Address(
-                    name=f'{self.name}Pager',
-                    package=self.ident.api_naming.module_namespace + (self.ident.api_naming.versioned_module_name,) + self.ident.subpackage + (
-                        'services',
-                        utils.to_snake_case(self.ident.parent[-1]),
-                    ),
-                    module='pagers',
-                    collisions=self.input.ident.collisions,
-                ),
-                documentation=utils.doc(
-                    f'{self.output.meta.doc}\n\n'
-                    'Iterating over this object will yield results and '
-                    'resolve additional pages automatically.',
-                ),
-            ))
-
-        # Return the usual output.
-        return self.output
+        return self._client_output(enable_asyncio=False)
 
     @utils.cached_property
     def client_output_async(self):
+        return self._client_output(enable_asyncio=True)
+
+    def _client_output(self, enable_asyncio: bool):
         """Return the output from the client layer.
 
         This takes into account transformations made by the outer GAPIC
@@ -613,8 +563,8 @@ def client_output_async(self):
         if self.lro:
             return PythonType(meta=metadata.Metadata(
                 address=metadata.Address(
-                    name='AsyncOperation',
-                    module='operation_async',
+                    name='AsyncOperation' if enable_asyncio else 'Operation',
+                    module='operation_async' if enable_asyncio else 'operation',
                     package=('google', 'api_core'),
                     collisions=self.lro.response_type.ident.collisions,
                 ),
@@ -628,11 +578,11 @@ def client_output_async(self):
                 ),
             ))
 
-        # # If this method is paginated, return that method's pager class.
+        # If this method is paginated, return that method's pager class.
         if self.paged_result_field:
             return PythonType(meta=metadata.Metadata(
                 address=metadata.Address(
-                    name=f'{self.name}AsyncPager',
+                    name=f'{self.name}AsyncPager' if enable_asyncio else f'{self.name}Pager',
                     package=self.ident.api_naming.module_namespace + (self.ident.api_naming.versioned_module_name,) + self.ident.subpackage + (
                         'services',
                         utils.to_snake_case(self.ident.parent[-1]),