piper::Sender::send does not have a struct equivalent

[jjl]

I can't seem to figure out a way to send a message on a channel without boxing. Is there something I'm missing?

[wusyong]

Looks like modules from piper are from async_std. You can just import them directly. Does something this work for you?

fn main() -> io::Result<()> {
    smol::run(async {
        let (s, r) = async_std::sync::channel(1);
        smol::Task::spawn( async move {s.send(2).await;} ).await;
        
        let x = r.recv().await;

        Ok(())
    })
}

[jjl]

I'm trying to avoid having to spawn a new task.

I've started translating the current code into a Sending object. It's a bit horrific at the moment, but let's see how it goes.

[ghost]

I empathize with having to box futures to get a concrete type. This will get easier once the language supports impl Trait in more positions than it currently does.

Instead of using Task::spawn(), I suggest using .boxed() instead (exists in FutureExt) like so:

let (s, r) = piper::chan(1);
let fut: BoxFuture<'_, ()> = s.send("hello").boxed();
fut.await;

Looks like modules from piper are from async_std.

They're based on async-std's implementation of channels, but improved in many ways. For example, piper's channels can have capacity of zero. There's also try_recv(). They also have a successor of of WakerSet that is based on doubly-linked list and serves tasks in FIFO order, thus improving fairness.

[ghost]

This is something that will be solved by impl Trait in more places soon (hopefully!). Closing.