bastion-rs
/
bastion
mirror of https://github.com/bastion-rs/bastion
1
0
Fork 0
Code Issues Releases Wiki Activity

Change the supervisor creation order in the broadcast message example (#270)

This commit is contained in:
Jeremy Lempereur 2021-02-03 17:26:02 +01:00 committed by GitHub
parent 0693624dc8
commit 0d159ea483
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/bastion/examples/broadcast_message.rs
View File

@ -32,9 +32,9 @@ fn main() {
Bastion::init();
Bastion::supervisor(input_supervisor)
Bastion::supervisor(response_supervisor)
.and_then(|_| Bastion::supervisor(map_supervisor))
.and_then(|_| Bastion::supervisor(response_supervisor))
.and_then(|_| Bastion::supervisor(input_supervisor))
.expect("Couldn't create supervisor chain.");
Bastion::start();
@ -59,7 +59,7 @@ fn response_supervisor(supervisor: Supervisor) -> Supervisor {
fn input_group(children: Children) -> Children {
children.with_name("input").with_redundancy(1).with_exec(
move |ctx: BastionContext| async move {
println!("[Input] Worker started!");
tracing::info!("[Input] Worker started!");
let data = vec!["A B C", "A C C", "B C C"];
let group_name = "Processing".to_string();
@ -87,7 +87,7 @@ fn process_group(children: Children) -> Children {
Dispatcher::with_type(DispatcherType::Named("Processing".to_string())),
)
.with_exec(move |ctx: BastionContext| async move {
println!("[Processing] Worker started!");
tracing::info!("[Processing] Worker started!");
msg! { ctx.recv().await?,
// We received the message from other actor wrapped in Arc<T>
@ -135,7 +135,7 @@ fn response_group(children: Children) -> Children {
)
.with_exec(move |ctx: BastionContext| {
async move {
println!("[Response] Worker started!");
tracing::info!("[Response] Worker started!");
let mut received_messages = 0;
let expected_messages = 3;