Method send_data

crates/hyperqueue/src/worker/streamer.rs:138–157

(&self, channel: ChannelId, data: Vec<u8>)

    }

    pub async fn send_data(&self, channel: ChannelId, data: Vec<u8>) -> tako::Result<()> {
        if self
            .sender
            .send(StreamerMessage::Write {
                header: StreamChunkHeader {
                    time: Utc::now(),
                    task: self.task_id,
                    instance: self.instance_id,
                    channel,
                    size: data.len() as u64,
                },
                data,
            })
            .await
            .is_err()
        {
            return Err("Sending streamer message failed".into());
        }
        Ok(())
    }
}

async fn stream_writer(