First pass at a select statement

Author: slinkydeveloper

src/context/macro_support.rs

@@ -2,6 +2,7 @@ use crate::endpoint::ContextInternal;
 use restate_sdk_shared_core::NotificationHandle;
 
 // Sealed future trait, used by select statement
+#[doc(hidden)]
 pub trait SealedDurableFuture {
     fn inner_context(&self) -> ContextInternal;
     fn handle(&self) -> NotificationHandle;

src/context/select.rs

@@ -1,3 +1,7 @@
+// Thanks tokio for the help!
+// https://github.com/tokio-rs/tokio/blob/a258bff7018940b438e5de3fb846588454df4e4d/tokio/src/macros/select.rs
+// MIT License
+
 /// Select macro, alike tokio::select:
 ///
 /// ```rust

test-services/src/virtual_object_command_interpreter.rs

@@ -106,7 +106,10 @@ impl VirtualObjectCommandInterpreter for VirtualObjectCommandInterpreterImpl {
                 Command::AwaitAnySuccessful { .. } => Err(anyhow!(
                     "AwaitAnySuccessful is currently unsupported in the Rust SDK"
                 ))?,
-                Command::AwaitAwakeableOrTimeout { awakeable_key, timeout_millis } => {
+                Command::AwaitAwakeableOrTimeout {
+                    awakeable_key,
+                    timeout_millis,
+                } => {
                     let (awakeable_id, awk_fut) = context.awakeable::<String>();
                     context.set::<String>(&format!("awk-{awakeable_key}"), awakeable_id);
 
@@ -118,7 +121,7 @@ impl VirtualObjectCommandInterpreter for VirtualObjectCommandInterpreterImpl {
                             Err(TerminalError::new("await-timeout"))
                         }
                     }?;
-                },
+                }
                 Command::AwaitOne { command } => {
                     last_result = match command {
                         AwaitableCommand::CreateAwakeable { awakeable_key } => {