dex-sdk 1.38.0

Strongly typed Rust SDK for Dex
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

// Portions of this file are derived from indeedeng/iwf-java-sdk.
// Those portions are licensed under the Apache License, Version 2.0.
// See LICENSES/Apache-2.0.txt and LEGACY_NOTICES.md.
//
// Modifications Copyright (c) 2026 Super Durable, Inc.
//
// Modifications are licensed under the Sustainable Use License 1.0.
// Third-Party Materials remain under the Apache License, Version 2.0.
// See LICENSE and LEGACY_NOTICES.md.

use dex_sdk::{Context, Flow, HandlerResult, Step, StepDecision, StepList, StepMovement};

pub(crate) struct MultiOutputWorkflow {
    pub(crate) string_step: MultiOutputStringStep,
    pub(crate) integer_step: MultiOutputIntegerStep,
    start: MultiOutputStartStep,
}

impl MultiOutputWorkflow {
    pub(crate) fn new() -> Self {
        Self {
            string_step: MultiOutputStringStep,
            integer_step: MultiOutputIntegerStep,
            start: MultiOutputStartStep,
        }
    }
}

impl Flow for MultiOutputWorkflow {
    type StartInput = ();

    fn steps(&self) -> StepList<'_, Self::StartInput> {
        StepList::start(&self.start)
            .and(&self.string_step)
            .and(&self.integer_step)
    }
}

struct MultiOutputStartStep;

impl Step for MultiOutputStartStep {
    type Input = ();

    fn execute(&self, _context: &mut Context, _input: ()) -> HandlerResult<StepDecision> {
        Ok(StepDecision::go_to_many([
            StepMovement::to(&MultiOutputStringStep, ()),
            StepMovement::to(&MultiOutputIntegerStep, ()),
        ]))
    }
}

pub(crate) struct MultiOutputStringStep;

impl Step for MultiOutputStringStep {
    type Input = ();

    fn execute(&self, _context: &mut Context, _input: ()) -> HandlerResult<StepDecision> {
        Ok(StepDecision::graceful_complete("branch-one".to_string()))
    }
}

pub(crate) struct MultiOutputIntegerStep;

impl Step for MultiOutputIntegerStep {
    type Input = ();

    fn execute(&self, _context: &mut Context, _input: ()) -> HandlerResult<StepDecision> {
        Ok(StepDecision::graceful_complete(42_i32))
    }
}