Skip to content

Commit 20070d2

Browse files
chore(deps): update rust crate oneshot to 0.2.0 (#7042)
This PR contains the following updates: | Package | Type | Update | Change | |---|---|---|---| | [oneshot](https://redirect.github.com/faern/oneshot) | workspace.dependencies | minor | `0.1.13` → `0.2.0` | --- ### Release Notes <details> <summary>faern/oneshot (oneshot)</summary> ### [`v0.2.1`](https://redirect.github.com/faern/oneshot/blob/HEAD/CHANGELOG.md#021---2026-02-23) [Compare Source](https://redirect.github.com/faern/oneshot/compare/v0.2.0...v0.2.1) ##### Added - Add `is_closed` and `has_message` methods to `AsyncReceiver`. ### [`v0.2.0`](https://redirect.github.com/faern/oneshot/blob/HEAD/CHANGELOG.md#020---2026-02-23) [Compare Source](https://redirect.github.com/faern/oneshot/compare/v0.1.13...v0.2.0) ##### Changed - Disable both the `std` and `async` features by default. Making them opt-in instead of opt-out. This makes the library more minimal by default and only contains the functionality that the user explicitly enables. This is a breaking change. - Upgrade to Rust 2024 edition. This also bumps the MSRV to 1.85.0 - Add a separate type `AsyncReceiver` that implements `Future` instead of implementing it directly on the `Receiver` type. Now the `Receiver` implements `IntoFuture` instead. This is a breaking change. This change removes the possible panics in many recv\* methods, and it simplifies some code a bit. ##### Fixed - Make Debug impl on SendError include the channel message type, instead of just saying `"SendError<T>(_)"`. </details> --- ### Configuration 📅 **Schedule**: Branch creation - Between 12:00 AM and 03:59 AM, only on Monday ( * 0-3 * * 1 ) (UTC), Automerge - At any time (no schedule defined). 🚦 **Automerge**: Enabled. ♻ **Rebasing**: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox. 🔕 **Ignore**: Close this PR and you won't be reminded about this update again. --- - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, check this box --- This PR was generated by [Mend Renovate](https://mend.io/renovate/). View the [repository job log](https://developer.mend.io/github/vortex-data/vortex). <!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiI0My42Ni40IiwidXBkYXRlZEluVmVyIjoiNDMuNjYuNCIsInRhcmdldEJyYW5jaCI6ImRldmVsb3AiLCJsYWJlbHMiOlsiY2hhbmdlbG9nL2Nob3JlIl19--> --------- Signed-off-by: Robert Kruszewski <github@robertk.io> Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com> Co-authored-by: Robert Kruszewski <github@robertk.io>
1 parent 27c06b4 commit 20070d2

4 files changed

Lines changed: 17 additions & 11 deletions

File tree

Cargo.lock

Lines changed: 10 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ num-traits = "0.2.19"
178178
num_enum = { version = "0.7.3", default-features = false }
179179
object_store = { version = "0.12.4", default-features = false }
180180
once_cell = "1.21"
181-
oneshot = "0.1.13"
181+
oneshot = { version = "0.2.0", features = ["async"] }
182182
opentelemetry = "0.31.0"
183183
opentelemetry-otlp = "0.31.0"
184184
opentelemetry_sdk = "0.31.0"

vortex-file/src/segments/source.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ impl SegmentSource for FileSegmentSource {
167167

168168
let fut = ReadFuture {
169169
id,
170-
recv,
170+
recv: recv.into_future(),
171171
polled: false,
172172
finished: false,
173173
events: self.events.clone(),
@@ -184,7 +184,7 @@ impl SegmentSource for FileSegmentSource {
184184
/// If dropped, the read request will be canceled where possible.
185185
struct ReadFuture {
186186
id: usize,
187-
recv: oneshot::Receiver<VortexResult<BufferHandle>>,
187+
recv: oneshot::AsyncReceiver<VortexResult<BufferHandle>>,
188188
polled: bool,
189189
finished: bool,
190190
events: mpsc::UnboundedSender<ReadEvent>,

vortex-io/src/runtime/handle.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ impl Handle {
7676
.boxed(),
7777
);
7878
Task {
79-
recv,
79+
recv: recv.into_future(),
8080
abort_handle: Some(abort_handle),
8181
}
8282
}
@@ -116,7 +116,7 @@ impl Handle {
116116
}
117117
}));
118118
Task {
119-
recv,
119+
recv: recv.into_future(),
120120
abort_handle: Some(abort_handle),
121121
}
122122
}
@@ -138,7 +138,7 @@ impl Handle {
138138
}
139139
}));
140140
Task {
141-
recv,
141+
recv: recv.into_future(),
142142
abort_handle: Some(abort_handle),
143143
}
144144
}
@@ -150,7 +150,7 @@ impl Handle {
150150
/// continue running in the background, call [`Task::detach`].
151151
#[must_use = "When a Task is dropped without being awaited, it is cancelled"]
152152
pub struct Task<T> {
153-
recv: oneshot::Receiver<T>,
153+
recv: oneshot::AsyncReceiver<T>,
154154
abort_handle: Option<AbortHandleRef>,
155155
}
156156

0 commit comments

Comments
 (0)