How to receive result in a sync function in the Actor pattern?

[cjwcommuny]

The Tokio tutorial have the following code (the actor pattern):

use tokio::runtime::Builder;
use tokio::sync::mpsc;

pub struct Task {
    name: String,
    // info that describes the task
}

async fn handle_task(task: Task) {
    println!("Got task {}", task.name);
}

#[derive(Clone)]
pub struct TaskSpawner {
    spawn: mpsc::Sender<Task>,
}

impl TaskSpawner {
    pub fn new() -> TaskSpawner {
        // Set up a channel for communicating.
        let (send, mut recv) = mpsc::channel(16);

        // Build the runtime for the new thread.
        //
        // The runtime is created before spawning the thread
        // to more cleanly forward errors if the `unwrap()`
        // panics.
        let rt = Builder::new_current_thread()
            .enable_all()
            .build()
            .unwrap();

        std::thread::spawn(move || {
            rt.block_on(async move {
                while let Some(task) = recv.recv().await {
                    tokio::spawn(handle_task(task));
                }

                // Once all senders have gone out of scope,
                // the `.recv()` call returns None and it will
                // exit from the while loop and shut down the
                // thread.
            });
        });

        TaskSpawner {
            spawn: send,
        }
    }

    pub fn spawn_task(&self, task: Task) {
        match self.spawn.blocking_send(task) {
            Ok(()) => {},
            Err(_) => panic!("The shared runtime has shut down."),
        }
    }
}

How can I implement the following method, which wait for the result String sent from the actor:

impl TaskSpawner {
    pub fn spawn_my_task(&self, task_name: String) -> String {
        todo!()
    }
}

I tried to add the tokio::oneshot::Sender<String> to the Task:

pub struct Task {
    name: String,
    sender: tokio::oneshot::Sender<String>,
}

But tokio::oneshot:Receiver<String> has no sync method to wait for the result String. So, I cannot receive the result String inside the spawn_my_task method.

[cjwcommuny]

Ok, I found the solution: just use tokio::oneshot:Receiver<T>::blocking_recv

[cdbennett]

Not sure if you have already seen this, but such an awesome article, I will post it for anyone else reading this also:

Actors with Tokio by Alice Ryhl