File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 1919await sender.send("Hello, world!")
2020```
2121
22- Even when [`send()`][frequenz.channels.Sender.send] is an asynchronous method, some
23- channels may implement it as a synchronously . For example, buffered channels that
24- drop messages when the buffer is full could guarantee that
22+ Although [`send()`][frequenz.channels.Sender.send] is an asynchronous method, some
23+ channels may implement it in a synchronous, non-blocking way . For example, buffered
24+ channels that drop messages when the buffer is full could guarantee that
2525[`send()`][frequenz.channels.Sender.send] never blocks. However, please keep in mind
2626that the [asyncio][] event loop could give control to another task at any time,
2727effectively making the [`send()`][frequenz.channels.Sender.send] method blocking.
5858
5959
6060class Sender (ABC , Generic [_T ]):
61- """An entity that sends values to a *channel* ."""
61+ """An endpoint to sends messages ."""
6262
6363 @abstractmethod
6464 async def send (self , msg : _T ) -> None :
You can’t perform that action at this time.
0 commit comments