Create a channel receiver that will get notifications for byte-level progress of layer fetches.
(
&mut self,
)
| 728 | |
| 729 | /// Create a channel receiver that will get notifications for byte-level progress of layer fetches. |
| 730 | pub fn request_layer_progress( |
| 731 | &mut self, |
| 732 | ) -> tokio::sync::watch::Receiver<Option<LayerProgress>> { |
| 733 | assert!(self.layer_byte_progress.is_none()); |
| 734 | let (s, r) = tokio::sync::watch::channel(None); |
| 735 | self.layer_byte_progress = Some(s); |
| 736 | r |
| 737 | } |
| 738 | |
| 739 | /// Serialize the metadata about a pending fetch as detached metadata on the commit object, |
| 740 | /// so it can be retrieved later offline |
no outgoing calls
no test coverage detected