| Commit message (Collapse) | Author | Age | Files |
| |
|
| |
|
|
|
|
| |
new tasks
|
|
|
|
|
|
|
|
|
|
|
| |
bounded channels
Remove all unbounded channels to prevent unbounded memory usage and
potential crashes.
Use `FuturesUnordered` for sending to multiple channels simultaneously.
This prevents the sending loop from blocking if one channel is blocked,
and helps handle errors properly.
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
`ServerBuilder` and `ClientBuilder`
|
| |
|
|
|
|
|
|
| |
Add a limit for receiving notifications for the subscription. If this
limit is exceeded, the client will stop and raise an error. The limit is
configurable when building a new client.
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
clean up examples
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
executor & remove GlobalExecutor type
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
to Conn and Listener.
|
| |
|
| |
|