You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
PR #191 added the choice of a bounded or unbounded channel in an async/await client. We should do the same thing for the sync channel created in AsyncClient::start_consuming().
But as this would be a breaking change for the function signature, it needs to wait for the next major update.
I assume it would be implemented in the same way as the async stream, something like:
pub fn start_consuming<L>(&mut self, buffer_lim: L) -> Receiver<Option<Message>>
where
L: Into<Option<usize>>,
{
let (tx, rx) = match buffer_lim.into() {
None => channel::unbounded(),
Some(lim) => channel::bounded(lim),
};
...
The text was updated successfully, but these errors were encountered:
PR #191 added the choice of a bounded or unbounded channel in an async/await client. We should do the same thing for the sync channel created in
AsyncClient::start_consuming()
.But as this would be a breaking change for the function signature, it needs to wait for the next major update.
I assume it would be implemented in the same way as the async stream, something like:
The text was updated successfully, but these errors were encountered: