-
Notifications
You must be signed in to change notification settings - Fork 5
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[MET-44]rocks gap filler server #19
Conversation
6d40393
to
b285204
Compare
let (tx, rx) = tokio::sync::mpsc::channel(32); | ||
let backend = self.slot_asset_idx.backend.clone(); | ||
|
||
tokio::spawn(async move { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If I'm not mistaken our graceful stop is not propagating onto this one task because in main.rs we have JoinSet to handle all the tasks(workers) and here we create new JoinHandle by calling tokio::spawn and do not process it anyhow. So if we need graceful stop for this operation I think we have to use JoinSet which we are defining in main.rs file
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Presumably fixed it, please have another look and verify the approach.
3f4da7c
to
542a759
Compare
An implementation of the asset streaming service for rocksdb.