@@ -107,9 +107,7 @@ async def connect():
107107
108108 os .close (wpipe )
109109 self .loop .run_until_complete (proto .done )
110- self .assertEqual (
111- ["INITIAL" , "CONNECTED" , "EOF" , "CLOSED" ], proto .state
112- )
110+ self .assertEqual (["INITIAL" , "CONNECTED" , "EOF" , "CLOSED" ], proto .state )
113111 # extra info is available
114112 self .assertIsNotNone (proto .transport .get_extra_info ("pipe" ))
115113
@@ -121,9 +119,7 @@ def test_read_pty_output(self):
121119 master_read_obj = io .open (master , "rb" , 0 )
122120
123121 async def connect ():
124- t , p = await self .loop .connect_read_pipe (
125- lambda : proto , master_read_obj
126- )
122+ t , p = await self .loop .connect_read_pipe (lambda : proto , master_read_obj )
127123 self .assertIs (p , proto )
128124 self .assertIs (t , proto .transport )
129125 self .assertEqual (["INITIAL" , "CONNECTED" ], proto .state )
@@ -147,9 +143,7 @@ async def connect():
147143 proto .transport .close ()
148144 self .loop .run_until_complete (proto .done )
149145
150- self .assertEqual (
151- ["INITIAL" , "CONNECTED" , "EOF" , "CLOSED" ], proto .state
152- )
146+ self .assertEqual (["INITIAL" , "CONNECTED" , "EOF" , "CLOSED" ], proto .state )
153147 # extra info is available
154148 self .assertIsNotNone (proto .transport .get_extra_info ("pipe" ))
155149
0 commit comments