@@ -19,4 +19,4 @@
 except ImportError:
     import pkgutil
 
-    __path__ = pkgutil.extend_path(__path__, __name__)
+    __path__ = pkgutil.extend_path(__path__, __name__)  # type: ignore
@@ -612,7 +612,7 @@ def _make_invalid(self):
         """
         self._invalid = True
 
-    async def _process_response(self, response, bytes_sent):
+    async def _process_resumable_response(self, response, bytes_sent):
         """Process the response from an HTTP request.
 
         This is everything that must be done after a request that doesn't
 
@@ -23,8 +23,8 @@
 from google._async_resumable_media import _helpers
 from google.resumable_media import common
 
-import google.auth.transport._aiohttp_requests as aiohttp_requests
-import aiohttp
+from google.auth.transport import _aiohttp_requests as aiohttp_requests  # type: ignore
+import aiohttp  # type: ignore
 
 _DEFAULT_RETRY_STRATEGY = common.RetryStrategy()
 _SINGLE_GET_CHUNK_SIZE = 8192
 
@@ -14,7 +14,7 @@
 
 """Support for downloading media from Google APIs."""
 
-import urllib3.response
+import urllib3.response  # type: ignore
 
 from google._async_resumable_media import _download
 from google._async_resumable_media import _helpers
 
@@ -481,7 +481,7 @@ async def transmit_next_chunk(
             retry_strategy=self._retry_strategy,
             timeout=timeout,
         )
-        await self._process_response(response, len(payload))
+        await self._process_resumable_response(response, len(payload))
         return response
 
     async def recover(self, transport):
 
@@ -140,12 +140,12 @@ def _get_crc32c_object():
     to use CRCMod. CRCMod might be using a 'slow' varietal. If so, warn...
     """
     try:
-        import google_crc32c
+        import google_crc32c  # type: ignore
 
         crc_obj = google_crc32c.Checksum()
     except ImportError:
         try:
-            import crcmod
+            import crcmod  # type: ignore
 
             crc_obj = crcmod.predefined.Crc("crc-32c")
             _is_fast_crcmod()
 
@@ -647,7 +647,7 @@ def _make_invalid(self):
         """
         self._invalid = True
 
-    def _process_response(self, response, bytes_sent):
+    def _process_resumable_response(self, response, bytes_sent):
         """Process the response from an HTTP request.
 
         This is everything that must be done after a request that doesn't
 
@@ -26,7 +26,7 @@
 UPLOAD_CHUNK_SIZE = 262144  # 256 * 1024
 """int: Chunks in a resumable upload must come in multiples of 256 KB."""
 
-PERMANENT_REDIRECT = http.client.PERMANENT_REDIRECT
+PERMANENT_REDIRECT = http.client.PERMANENT_REDIRECT  # type: ignore
 """int: Permanent redirect status code.
 
 .. note::
 
@@ -0,0 +1,2 @@
+# Marker file for PEP 561.
+# The google-resumable_media package uses inline types.
@@ -18,7 +18,7 @@
 """
 
 import requests.exceptions
-import urllib3.exceptions
+import urllib3.exceptions  # type: ignore
 
 import time
Original file line number	Diff line number	Diff line change
`@@ -481,7 +481,7 @@ async def transmit_next_chunk(`
`481`	`481`	`retry_strategy=self._retry_strategy,`
`482`	`482`	`timeout=timeout,`
`483`	`483`	`)`
`484`		`- await self._process_response(response, len(payload))`
	`484`	`+ await self._process_resumable_response(response, len(payload))`
`485`	`485`	`return response`
`486`	`486`
`487`	`487`	`async def recover(self, transport):`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+# Marker file for PEP 561.`
	`2`	`+# The google-resumable_media package uses inline types.`