restate-sdk 0.10.0

Restate SDK for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use crate::endpoint::Error;
use tokio::sync::oneshot;

pub(super) struct HandlerStateNotifier {
    tx: Option<oneshot::Sender<Error>>,
}

impl HandlerStateNotifier {
    pub(crate) fn new() -> (Self, oneshot::Receiver<Error>) {
        let (tx, rx) = oneshot::channel();
        (Self { tx: Some(tx) }, rx)
    }

    pub(super) fn mark_error(&mut self, err: Error) {
        if let Some(tx) = self.tx.take() {
            let _ = tx.send(err);
        }
        // Some other operation already marked this handler as errored.
    }
}