async_flow/io/
output_port.rs

1// This is free and unencumbered software released into the public domain.
2
3use crate::io::SendError;
4use alloc::boxed::Box;
5
6#[async_trait::async_trait]
7pub trait OutputPort<T: Send + 'static> {
8    async fn send(&self, value: T) -> Result<(), SendError>;
9
10    // TODO: send_event
11    // TODO: send_deadline
12    // TODO: send_timeout
13    // TODO: try_send
14}