struct MyActivity { id: usize };
struct MyMessage { text: String };

pub fn main() {
    let activity = nuts::new_activity(MyActivity { id: 0 } );
    activity.subscribe(
        |activity: &mut MyActivity, message: &MyMessage|
        println!("Subscriber with ID {} received text: {}", activity.id, message.text)
    );
}

在上面的示例中，创建了一个订阅，等待发布类型为 MyMessage 的消息。到目前为止，闭包中的代码还没有执行，控制台也没有打印任何内容。

请注意，闭包的第一个参数是对活动对象的可变引用。第二个参数是对发布消息的只读引用。两种类型必须完全匹配，否则编译器将不接受闭包。

也可以使用具有正确参数类型的函数来订阅。

struct MyActivity { id: usize };
struct MyMessage { text: String };

pub fn main() {
    let activity = nuts::new_activity(MyActivity { id: 0 } );
    activity.subscribe(MyActivity::print_text);
}

impl MyActivity {
    fn print_text(&mut self, message: &MyMessage) {
        println!("Subscriber with ID {} received text: {}", self.id, message.text)
    }
}

示例：带有发布 + 订阅的基本活动

#[derive(Default)]
struct MyActivity {
    round: usize
}
struct MyMessage {
    no: usize
}

// Create activity
let activity = MyActivity::default();
// Activity moves into globally managed state, ID to handle it is returned
let activity_id = nuts::new_activity(activity);

// Add event listener that listens to published `MyMessage` types
activity_id.subscribe(
    |my_activity, msg: &MyMessage| {
        println!("Round: {}, Message No: {}", my_activity.round, msg.no);
        my_activity.round += 1;
    }
);

// prints "Round: 0, Message No: 1"
nuts::publish( MyMessage { no: 1 } );
// prints "Round: 1, Message No: 2"
nuts::publish( MyMessage { no: 2 } );

示例：私有通道

到目前为止，我向您展示的示例中，所有消息都是共享引用，并且发送到已注册到特定消息类型的所有监听器。另一种选择是使用私有通道。在这种情况下，发送者可以决定哪个监听活动将接收到消息。在这种情况下，消息的所有权被赋予监听者。

struct ExampleActivity {}
let id = nuts::new_activity(ExampleActivity {});
// `private_channel` works similar to `subscribe` but it owns the message.
id.private_channel(|_activity, msg: usize| {
    assert_eq!(msg, 7);
});
// `send_to` must be used instead of `publish` when using private channels.
// Which activity receives the message is decide by the first type parameter.
nuts::send_to::<ExampleActivity, _>(7usize);

活动生命周期

每个活动都有一个生命周期状态，可以使用 set_status 来改变。它从 LifecycleStatus::Active 开始。在Nuts的当前版本中，唯一的另一个状态是 LifecycleStatus::Inactive。

可以使用不活动状态暂时将活动置于休眠状态。在不活动状态时，活动将不会收到它已订阅的事件。可以使用订阅过滤器来更改此行为。（见 subscribe_masked）

如果状态从活动变为不活动，活动将调用其 on_leave 和 on_leave_domained 订阅。

如果状态从不活动变为活动，活动将调用其 on_enter 和 on_enter_domained 订阅。

域

域存储任意数据，以便在多个 活动 之间共享。库用户可以定义域的数量，但每个活动只能加入一个域。

域只应在数据需要在同一类型或不同类型的多项活动之间共享时使用。如果数据只被单个活动使用，通常更好的做法是将它存储在活动结构体本身中。

如果只使用一个域，也可以考虑使用 DefaultDomain 而不是创建自己的枚举。

目前，除了数据隔离之外，使用多个域并没有真正的优势。但未来有计划将活动根据其域在不同的线程中进行调度。

创建域

struct MyActivity;
let activity = nuts::new_activity(MyActivity);
activity.subscribe(
    |_, msg: &usize| {
        println!("Start of {}", msg);
        if *msg < 3 {
            nuts::publish( msg + 1 );
        }
        println!("End of {}", msg);
    }
);

nuts::publish(0usize);
// Output:
// Start of 0
// End of 0
// Start of 1
// End of 1
// Start of 2
// End of 2
// Start of 3
// End of 3

完整演示示例

使用坚果构建基本点击游戏的简单示例可在examples/clicker-game中找到。它需要已安装wasm-pack和npm。要运行示例，执行wasm-pack build，然后cd www; npm install; npm run start。这个示例仅展示了nuts的最低功能。