Add annotations to web_response.py

aiohttp/abc.py

@@ -6,6 +6,7 @@
 from typing import (TYPE_CHECKING, Any, Awaitable, Dict, Iterable, List,
                     Mapping, Optional, Tuple, Union)
 
+from multidict import CIMultiDict  # noqa
 from yarl import URL
 
 
@@ -148,6 +149,10 @@ def filter_cookies(self, request_url: URL) -> 'BaseCookie[str]':
 class AbstractStreamWriter(ABC):
     """Abstract stream writer."""
 
+    buffer_size = 0
+    output_size = 0
+    length = 0  # type: Optional[int]
+
     @abstractmethod
     async def write(self, chunk: bytes) -> None:
         """Write chunk into stream."""
@@ -160,6 +165,19 @@ async def write_eof(self, chunk: bytes=b'') -> None:
     async def drain(self) -> None:
         """Flush the write buffer."""
 
+    @abstractmethod
+    def enable_compression(self, encoding: str='deflate') -> None:
+        """Enable HTTP body compression"""
+
+    @abstractmethod
+    def enable_chunking(self) -> None:
+        """Enable HTTP chunked mode"""
+
+    @abstractmethod
+    async def write_headers(self, status_line: str,
+                            headers: 'CIMultiDict[str]') -> None:
+        """Write HTTP headers"""
+
 
 class AbstractAccessLogger(ABC):
     """Abstract writer to access log."""

aiohttp/helpers.py

@@ -567,8 +567,8 @@ class HeadersMixin:
     ATTRS = frozenset([
         '_content_type', '_content_dict', '_stored_content_type'])
 
-    _content_type = None
-    _content_dict = None
+    _content_type = None  # type: Optional[str]
+    _content_dict = None  # type: Optional[Dict[str, str]]
     _stored_content_type = sentinel
 
     def _parse_content_type(self, raw: str) -> None:

aiohttp/http.py

@@ -1,5 +1,6 @@
 import http.server
 import sys
+from typing import Mapping, Tuple  # noqa
 
 from . import __version__
 from .http_exceptions import HttpProcessingError
@@ -31,6 +32,6 @@
 
 
 SERVER_SOFTWARE = 'Python/{0[0]}.{0[1]} aiohttp/{1}'.format(
-    sys.version_info, __version__)
+    sys.version_info, __version__)  # type: str
 
-RESPONSES = http.server.BaseHTTPRequestHandler.responses
+RESPONSES = http.server.BaseHTTPRequestHandler.responses  # type: Mapping[int, Tuple[str, str]]  # noqa

aiohttp/http_writer.py

@@ -97,8 +97,8 @@ async def write(self, chunk: bytes,
 
         if chunk:
             if self.chunked:
-                chunk_len = ('%x\r\n' % len(chunk)).encode('ascii')
-                chunk = chunk_len + chunk + b'\r\n'
+                chunk_len_pre = ('%x\r\n' % len(chunk)).encode('ascii')
+                chunk = chunk_len_pre + chunk + b'\r\n'
 
             self._write(chunk)
 

aiohttp/web_log.py

@@ -173,13 +173,13 @@ def _format_r(request: BaseRequest,
     @staticmethod
     def _format_s(request: BaseRequest,
                   response: StreamResponse,
-                  time: float) -> str:
+                  time: float) -> int:
         return response.status
 
     @staticmethod
     def _format_b(request: BaseRequest,
                   response: StreamResponse,
-                  time: float) -> str:
+                  time: float) -> int:
         return response.body_length
 
     @staticmethod