Uniformize comments.

Author: aaugustin

src/websockets/asyncio/messages.py

@@ -141,8 +141,8 @@ async def get(self, decode: bool | None = None) -> Data:
 
         self.get_in_progress = True
 
-        # Locking with get_in_progress prevents concurrent execution until
-        # get() fetches a complete message or is cancelled.
+        # Locking with get_in_progress prevents concurrent execution
+        # until get() fetches a complete message or is cancelled.
 
         try:
             # First frame
@@ -208,8 +208,8 @@ async def get_iter(self, decode: bool | None = None) -> AsyncIterator[Data]:
 
         self.get_in_progress = True
 
-        # Locking with get_in_progress prevents concurrent execution until
-        # get_iter() fetches a complete message or is cancelled.
+        # Locking with get_in_progress prevents concurrent execution
+        # until get_iter() fetches a complete message or is cancelled.
 
         # If get_iter() raises an exception e.g. in decoder.decode(),
         # get_in_progress remains set and the connection becomes unusable.

src/websockets/sync/messages.py

@@ -128,10 +128,11 @@ def get(self, timeout: float | None = None, decode: bool | None = None) -> Data:
 
             if self.get_in_progress:
                 raise ConcurrencyError("get() or get_iter() is already running")
-
-            # Locking with get_in_progress ensures only one thread can get here.
             self.get_in_progress = True
 
+        # Locking with get_in_progress prevents concurrent execution
+        # until get() fetches a complete message or times out.
+
         try:
             deadline = Deadline(timeout)
 
@@ -198,12 +199,10 @@ def get_iter(self, decode: bool | None = None) -> Iterator[Data]:
 
             if self.get_in_progress:
                 raise ConcurrencyError("get() or get_iter() is already running")
-
-            # Locking with get_in_progress ensures only one coroutine can get here.
             self.get_in_progress = True
 
-        # Locking with get_in_progress prevents concurrent execution until
-        # get_iter() fetches a complete message or is cancelled.
+        # Locking with get_in_progress prevents concurrent execution
+        # until get_iter() fetches a complete message or times out.
 
         # If get_iter() raises an exception e.g. in decoder.decode(),
         # get_in_progress remains set and the connection becomes unusable.