Trim trailing whitespace per pre-commit

Author: tekktrik

asyncio/core.py

@@ -70,7 +70,7 @@ def __next__(self):
 # Use a SingletonGenerator to do it without allocating on the heap
 def sleep_ms(t, sgen=SingletonGenerator()):
     """Sleep for `t` milliseconds.
-    
+
     This is a coroutine, and a MicroPython extension.
     """
 
@@ -82,7 +82,7 @@ def sleep_ms(t, sgen=SingletonGenerator()):
 # Pause task execution for the given time (in seconds)
 def sleep(t):
     """Sleep for `t` seconds
-    
+
     This is a coroutine.
     """
 
@@ -167,7 +167,7 @@ def _promote_to_task(aw):
 # Create and schedule a new task from a coroutine
 def create_task(coro):
     """Create a new task from the given coroutine and schedule it to run.
-    
+
     Returns the corresponding `Task` object.
     """
 
@@ -254,10 +254,10 @@ def run_until_complete(main_task=None):
 # Create a new task from a coroutine and run it until it finishes
 def run(coro):
     """Create a new task from the given coroutine and run it until it completes.
-    
+
     Returns the value returned be *coro*.
     """
-    
+
     return run_until_complete(create_task(coro))
 
 
@@ -354,7 +354,7 @@ def current_task():
 
 def new_event_loop():
     """Reset the event loop and return it.
-    
+
     **NOTE**: Since MicroPython only has a single event loop, this function just resets
     the loop's state, it does not create a new one
     """

asyncio/funcs.py

@@ -73,7 +73,7 @@ def runner(waiter, aw):
 
 def wait_for_ms(aw, timeout):
     """Similar to `wait_for` but *timeout* is an integer in milliseconds.
-    
+
     This is a coroutine, and a MicroPython extension.
     """
 
@@ -83,9 +83,9 @@ def wait_for_ms(aw, timeout):
 async def gather(*aws, return_exceptions=False):
     """Run all *aws* awaitables concurrently. Any *aws* that are not tasks
     are promoted to tasks.
-    
+
     Returns a list of return values of all *aws*
-    
+
     This is a coroutine.
     """
 

asyncio/lock.py

@@ -17,7 +17,7 @@
 class Lock:
     """Create a new lock which can be used to coordinate tasks. Locks start in
     the unlocked state.
-    
+
     In addition to the methods below, locks can be used in an ``async with``
     statement.
     """
@@ -55,7 +55,7 @@ def release(self):
     async def acquire(self):
         """Wait for the lock to be in the unlocked state and then lock it in an
         atomic way. Only one task can acquire the lock at any one time.
-        
+
         This is a coroutine.
         """
 

asyncio/stream.py

@@ -43,7 +43,7 @@ def close(self):
 
     async def wait_closed(self):
         """Wait for the stream to close.
-        
+
         This is a coroutine.
         """
 
@@ -52,7 +52,7 @@ async def wait_closed(self):
 
     async def read(self, n):
         """Read up to *n* bytes and return them.
-        
+
         This is a coroutine.
         """
 
@@ -61,9 +61,9 @@ async def read(self, n):
 
     async def readinto(self, buf):
         """Read up to n bytes into *buf* with n being equal to the length of *buf*
-        
+
         Return the number of bytes read into *buf*
-        
+
         This is a coroutine, and a MicroPython extension.
         """
 
@@ -72,7 +72,7 @@ async def readinto(self, buf):
 
     async def readexactly(self, n):
         """Read exactly *n* bytes and return them as a bytes object.
-        
+
         Raises an ``EOFError`` exception if the stream ends before reading
         *n* bytes.
 
@@ -92,7 +92,7 @@ async def readexactly(self, n):
 
     async def readline(self):
         """Read a line and return it.
-        
+
         This is a coroutine.
         """
 
@@ -114,7 +114,7 @@ def write(self, buf):
 
     async def drain(self):
         """Drain (write) all buffered output data out to the stream.
-        
+
         This is a coroutine.
         """
 
@@ -137,10 +137,10 @@ async def drain(self):
 async def open_connection(host, port):
     """Open a TCP connection to the given *host* and *port*. The *host* address will
     be resolved using `socket.getaddrinfo`, which is currently a blocking call.
-    
+
     Returns a pair of streams: a reader and a writer stream. Will raise a socket-specific
     ``OSError`` if the host could not be resolved or if the connection could not be made.
-    
+
     This is a coroutine.
     """
 
@@ -182,7 +182,7 @@ def close(self):
 
     async def wait_closed(self):
         """Wait for the server to close.
-        
+
         This is a coroutine.
         """
 
@@ -213,9 +213,9 @@ async def start_server(cb, host, port, backlog=5):
     """Start a TCP server on the given *host* and *port*. The *cb* callback wil be
     called with incoming, accepted connections, and be passed 2 arguments: reader
     writer streams for the connection.
-    
+
     Returns a `Server` object.
-    
+
     This is a coroutine.
     """
 

asyncio/task.py

@@ -133,7 +133,7 @@ class Task:
     """This object wraps a coroutine into a running task. Tasks can be waited on
     using ``await task``, which will wait for the task to complete and reutnr the
     return value of the task.
-    
+
     Tasks should not be created directly, rather use `create_task` to create them.
     """
 
@@ -170,7 +170,7 @@ def __next__(self):
 
     def done(self):
         """Whether the task is complete."""
-        
+
         return not self.state
 
     def cancel(self):