Method flush

crates/hyperqueue/src/worker/streamer.rs:122–136

(&self)

impl StreamSender {
    pub async fn flush(&self) -> tako::Result<()> {
        let (sender, receiver) = oneshot::channel();
        if self
            .sender
            .send(StreamerMessage::Flush(sender))
            .await
            .is_err()
        {
            return Err("Sending flush message failed".into());
        }
        receiver.await.map_err(|_| {
            tako::Error::GenericError("Stream failed while flushing stream".to_string())
        })?;
        Ok(())
    }

    pub async fn send_data(&self, channel: ChannelId, data: Vec<u8>) -> tako::Result<()> {
        if self