We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 96f1c21 commit 6c5b2a2Copy full SHA for 6c5b2a2
scylla-rust-wrapper/src/future.rs
@@ -79,6 +79,10 @@ enum FutureError {
79
struct JoinHandleTimeout(JoinHandle<()>);
80
81
impl CassFuture {
82
+ pub(crate) fn make_ready_raw(res: CassFutureResult) -> CassOwnedSharedPtr<CassFuture, CMut> {
83
+ Self::new_ready(res).into_raw()
84
+ }
85
+
86
pub(crate) fn make_raw(
87
fut: impl Future<Output = CassFutureResult> + Send + 'static,
88
#[cfg(cpp_integration_testing)] recording_listener: Option<
@@ -133,8 +137,6 @@ impl CassFuture {
133
137
cass_fut
134
138
}
135
139
136
- // This is left just because it might be useful in tests.
- #[expect(unused)]
140
pub(crate) fn new_ready(r: CassFutureResult) -> Arc<Self> {
141
Arc::new(CassFuture {
142
state: Mutex::new(CassFutureState::default()),
0 commit comments