fix issues

Author: gvdongen

examples/services/my_workflow.rs

@@ -10,7 +10,7 @@ pub trait MyWorkflow {
 pub struct MyWorkflowImpl;
 
 impl MyWorkflow for MyWorkflowImpl {
-    async fn run(&self, ctx: WorkflowContext<'_>, req: String) -> Result<String, HandlerError> {
+    async fn run(&self, _ctx: WorkflowContext<'_>, _req: String) -> Result<String, HandlerError> {
         // implement workflow logic here
 
         Ok(String::from("success"))

src/context/mod.rs

@@ -8,7 +8,6 @@ use std::time::Duration;
 
 mod request;
 mod run;
-
 pub use request::{Request, RequestTarget};
 pub use run::{RunClosure, RunFuture, RunRetryPolicy};
 
@@ -268,7 +267,7 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextTimers<'ctx> for CTX {}
 /// You can do request-response calls to Services, Virtual Objects, and Workflows, in the following way:
 ///
 /// ```
-/// # #[path = "../examples/services"]
+/// # #[path = "../../examples/services"]
 /// # mod services;
 /// # use services::my_service::MyServiceClient;
 /// # use services::my_virtual_object::MyVirtualObjectClient;
@@ -331,7 +330,7 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextTimers<'ctx> for CTX {}
 /// Handlers can send messages (a.k.a. one-way calls, or fire-and-forget calls), as follows:
 ///
 /// ```
-/// # #[path = "../examples/services"]
+/// # #[path = "../../examples/services"]
 /// # mod services;
 /// # use services::my_service::MyServiceClient;
 /// # use services::my_virtual_object::MyVirtualObjectClient;
@@ -411,7 +410,7 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextTimers<'ctx> for CTX {}
 /// For example, assume a handler calls the same Virtual Object twice:
 ///
 /// ```
-/// # #[path = "../examples/services"]
+/// # #[path = "../../examples/services"]
 /// # mod services;
 /// # use services::my_virtual_object::MyVirtualObjectClient;
 /// # use restate_sdk::prelude::*;
@@ -577,7 +576,9 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextClient<'ctx> for CTX {}
 /// /// 3. Wait for the promise to be resolved
 /// let payload = promise.await?;
 /// # }
-/// # fn trigger_task_and_deliver_id(awakeable_id: String){}
+/// # async fn trigger_task_and_deliver_id(awakeable_id: String) -> Result<(), HandlerError>{
+/// #    Ok(())
+/// # }
 /// ```
 ///
 ///
@@ -609,10 +610,11 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextClient<'ctx> for CTX {}
 /// #
 /// # async fn handle(ctx: Context<'_>, id: String) -> Result<(), HandlerError> {
 /// // Resolve the awakeable
-/// ctx.resolve_awakeable(&id, "hello");
+/// ctx.resolve_awakeable(&id, "hello".to_string());
 ///
 /// // Or reject the awakeable
 /// ctx.reject_awakeable(&id, TerminalError::new("my error reason"));
+/// # Ok(())
 /// # }
 /// ```
 ///
@@ -665,7 +667,7 @@ impl<'ctx, CTX: private::SealedContext<'ctx>> ContextAwakeables<'ctx> for CTX {}
 /// let response = ctx.run(|| do_db_request()).await?;
 /// # Ok(())
 /// # }
-/// # fn do_db_request() -> Result<String, HandlerError>{
+/// # async fn do_db_request() -> Result<String, HandlerError>{
 /// # Ok("Hello".to_string())
 /// # }
 /// ```

src/http_server.rs

@@ -7,9 +7,11 @@
 //! 3. Listen on the specified port (default `9080`) for connections and requests.
 //!
 //! ```
-//! use crate::_examples::my_service::{MyService, MyServiceImpl};
-//! use crate::_examples::my_virtual_object::{MyVirtualObject, MyVirtualObjectImpl};
-//! use crate::_examples::my_workflow::{MyWorkflow, MyWorkflowImpl};
+//! # #[path = "../examples/services"]
+//! # mod services;
+//! # use services::my_service::{MyService, MyServiceImpl};
+//! # use services::my_virtual_object::{MyVirtualObject, MyVirtualObjectImpl};
+//! # use services::my_workflow::{MyWorkflow, MyWorkflowImpl};
 //! use restate_sdk::endpoint::Endpoint;
 //! use restate_sdk::http_server::HttpServer;
 //!
@@ -36,7 +38,9 @@
 //! Add the identity key to your endpoint as follows:
 //!
 //! ```
-//! # use crate::_examples::my_service::{MyService, MyServiceImpl};
+//! # #[path = "../examples/services"]
+//! # mod services;
+//! # use services::my_service::{MyService, MyServiceImpl};
 //! # use restate_sdk::endpoint::Endpoint;
 //! # use restate_sdk::http_server::HttpServer;
 //! #

src/lib.rs

@@ -389,10 +389,10 @@ pub use restate_sdk_macros::object;
 ///         Ok(())
 ///     }
 ///     async fn get_status(&self, ctx: SharedWorkflowContext<'_>) -> Result<String, HandlerError> {
-///         Ok(ctx.get("status").unwrap_or("unknown".to_string()))
+///         Ok(ctx.get("status").await?.unwrap_or("unknown".to_string()))
 ///     }
 /// }
-/// # fn send_email_with_link(email: String, secret: String) -> Result<(), HandlerError> {
+/// # async fn send_email_with_link(email: String, secret: String) -> Result<(), HandlerError> {
 /// #    Ok(())
 /// # }
 ///