|
AsyncServerToClientMessage::ChunkReservationExpired(chunk_id) => { |
|
tracing::info!("Server indicated that we took too long with {chunk_id:?}, and now our reservation has expired."); |
|
}, |
I would expect a local cancellation token that we can await to be informed we should stop processing the Chunk.
opsqueue/opsqueue/src/consumer/client.rs
Lines 293 to 295 in bd0a42e
I would expect a local cancellation token that we can await to be informed we should stop processing the
Chunk.