Fixing flake8 E121, E122, E123, E124, E125, E126 errors

stdlib/3.4/asyncio/streams.pyi

@@ -18,31 +18,34 @@ class LimitOverrunError(Exception):
 
 @coroutines.coroutine
 def open_connection(
-        host: str = ...,
-        port: int = ...,
-        *,
-        loop: events.AbstractEventLoop = ...,
-        limit: int = ...,
-        **kwds: Any) -> Generator[Any, None, Tuple[StreamReader, StreamWriter]]: ...
+    host: str = ...,
+    port: int = ...,
+    *,
+    loop: events.AbstractEventLoop = ...,
+    limit: int = ...,
+    **kwds: Any
+) -> Generator[Any, None, Tuple[StreamReader, StreamWriter]]: ...
 
 @coroutines.coroutine
 def start_server(
-        client_connected_cb: ClientConnectedCallback,
-        host: str = ...,
-        port: int = ...,
-        *,
-        loop: events.AbstractEventLoop = ...,
-        limit: int = ...,
-        **kwds: Any) -> Generator[Any, None, events.AbstractServer]: ...
+    client_connected_cb: ClientConnectedCallback,
+    host: str = ...,
+    port: int = ...,
+    *,
+    loop: events.AbstractEventLoop = ...,
+    limit: int = ...,
+    **kwds: Any
+) -> Generator[Any, None, events.AbstractServer]: ...
 
 if hasattr(socket, 'AF_UNIX'):
     @coroutines.coroutine
     def open_unix_connection(
-            path: str = ...,
-            *,
-            loop: events.AbstractEventLoop = ...,
-            limit: int = ...,
-            **kwds: Any)-> Generator[Any, None, Tuple[StreamReader, StreamWriter]]: ...
+        path: str = ...,
+        *,
+        loop: events.AbstractEventLoop = ...,
+        limit: int = ...,
+        **kwds: Any
+    ) -> Generator[Any, None, Tuple[StreamReader, StreamWriter]]: ...
 
     @coroutines.coroutine
     def start_unix_server(

stdlib/3.4/asyncio/subprocess.pyi

@@ -40,21 +40,23 @@ class Process:
 
 @coroutine
 def create_subprocess_shell(
-        *Args: Union[str, bytes],  # Union used instead of AnyStr due to mypy issue  #1236
-        stdin: int = ...,
-        stdout: int = ...,
-        stderr: int = ...,
-        loop: events.AbstractEventLoop = ...,
-        limit: int = ...,
-        **kwds: Any): ...
+    *Args: Union[str, bytes],  # Union used instead of AnyStr due to mypy issue  #1236
+    stdin: int = ...,
+    stdout: int = ...,
+    stderr: int = ...,
+    loop: events.AbstractEventLoop = ...,
+    limit: int = ...,
+    **kwds: Any
+): ...
 
 @coroutine
 def create_subprocess_exec(
-        program: Union[str, bytes],  # Union used instead of AnyStr due to mypy issue  #1236
-        *args: Any,
-        stdin: int = ...,
-        stdout: int = ...,
-        stderr: int = ...,
-        loop: events.AbstractEventLoop = ...,
-        limit: int = ...,
-        **kwds: Any) -> Process: ...
+    program: Union[str, bytes],  # Union used instead of AnyStr due to mypy issue  #1236
+    *args: Any,
+    stdin: int = ...,
+    stdout: int = ...,
+    stderr: int = ...,
+    loop: events.AbstractEventLoop = ...,
+    limit: int = ...,
+    **kwds: Any
+) -> Process: ...

stdlib/3.4/asyncio/transports.pyi

@@ -14,7 +14,8 @@ class ReadTransport(BaseTransport):
 
 class WriteTransport(BaseTransport):
     def set_write_buffer_limits(
-            self, high: int = ..., low: int = ...) -> None: ...
+        self, high: int = ..., low: int = ...
+    ) -> None: ...
     def get_write_buffer_size(self) -> int: ...
     def write(self, data: Any) -> None: ...
     def writelines(self, list_of_data: List[Any]): ...