Make assert msg grammatically correct and less ambiguous

Signed-off-by: Mathias L. Baumann <[email protected]>

Author: Marenz

src/frequenz/channels/_anycast.py

@@ -207,7 +207,7 @@ def consume(self) -> T:
 
         assert (
             self._next is not None
-        ), "calls to `consume()` must be follow a call to `ready()`"
+        ), "`consume()` must be preceeded by a call to `ready()`"
         next_val = self._next
         self._next = None
         return next_val

src/frequenz/channels/_broadcast.py

@@ -313,7 +313,7 @@ def consume(self) -> T:
         if not self._q and self._chan.closed:
             raise ReceiverStoppedError(self) from ChannelClosedError(self._chan)
 
-        assert self._q, "calls to `consume()` must be follow a call to `ready()`"
+        assert self._q, "`consume()` must be preceeded by a call to `ready()`"
         return self._q.popleft()
 
     def into_peekable(self) -> Peekable[T]:

src/frequenz/channels/util/_file_watcher.py

@@ -103,7 +103,7 @@ def consume(self) -> pathlib.Path:
         if not self._changes and self._awatch_stopped_exc is not None:
             raise ReceiverStoppedError(self) from self._awatch_stopped_exc
 
-        assert self._changes, "calls to `consume()` must be follow a call to `ready()`"
+        assert self._changes, "`consume()` must be preceeded by a call to `ready()`"
         change = self._changes.pop()
         # Tuple of (Change, path) returned by watchfiles
         _, path_str = change

src/frequenz/channels/util/_merge.py

@@ -105,6 +105,6 @@ def consume(self) -> T:
         if not self._results and not self._pending:
             raise ReceiverStoppedError(self)
 
-        assert self._results, "calls to `consume()` must be follow a call to `ready()`"
+        assert self._results, "`consume()` must be preceeded by a call to `ready()`"
 
         return self._results.popleft()

src/frequenz/channels/util/_merge_named.py

@@ -93,6 +93,6 @@ def consume(self) -> Tuple[str, T]:
         if not self._results and not self._pending:
             raise ReceiverStoppedError(self)
 
-        assert self._results, "calls to `consume()` must be follow a call to `ready()`"
+        assert self._results, "`consume()` must be preceeded by a call to `ready()`"
 
         return self._results.popleft()

src/frequenz/channels/util/_timer.py

@@ -129,7 +129,7 @@ def consume(self) -> datetime:
 
         assert (
             self._now is not None
-        ), "calls to `consume()` must be follow a call to `ready()`"
+        ), "`consume()` must be preceeded by a call to `ready()`"
         now = self._now
         self._now = None
         return now