-
Notifications
You must be signed in to change notification settings - Fork 170
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
refactor(async client): refactor background task (#1145)
* refactor(async client): refactor background task Split send and receive to separate tasks to support multiplexing reads/writes * fix tests * dont rely on tokio::spawn handles anymore * fix build * fix build again * switch to std::sync::Mutex * fix tests again * bench stuff * don't block in read task * fix build * fix nits * works now * revert bench code * replace unreachable with None * Revert "replace unreachable with None" This reverts commit 49edaee. * fix nits * use dashmap instead of Arc<Mutex<RequestManager> * Revert "use dashmap instead of Arc<Mutex<RequestManager>" This reverts commit d73aeeb. * refactor select loops prio for closed futs * grumbles: save waker to wake when new items are pushed * fix build * fix build again * fix some nits
- Loading branch information
Showing
13 changed files
with
454 additions
and
270 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.