Struct SkillMessageWriter 

pub struct SkillMessageWriter<W> { /* private fields */ }

Writes binary-framed skill messages to a stream.

Implementations

impl<W: AsyncWrite + Unpin> SkillMessageWriter<W>

pub fn new(writer: W) -> Self

pub async fn write_execute(&mut self, payload: &ExecutePayload) -> Result<()>

pub async fn write_cancel(&mut self, execution_id: &str) -> Result<()>

pub async fn write_stdin_data( &mut self, payload: &StdinDataPayload, ) -> Result<()>

pub async fn write_resize(&mut self, payload: &ResizePayload) -> Result<()>

pub async fn write_signal(&mut self, payload: &SignalPayload) -> Result<()>

pub async fn write_start_session( &mut self, payload: &StartSessionPayload, ) -> Result<()>

pub async fn write_shutdown(&mut self) -> Result<()>

pub async fn write_ack(&mut self, payload: &AckPayload) -> Result<()>

pub async fn write_stdout_chunk( &mut self, payload: &DataChunkPayload, ) -> Result<()>

pub async fn write_stderr_chunk( &mut self, payload: &DataChunkPayload, ) -> Result<()>

pub async fn write_progress(&mut self, payload: &ProgressPayload) -> Result<()>

pub async fn write_completed( &mut self, payload: &CompletedPayload, ) -> Result<()>

pub async fn write_error(&mut self, payload: &ErrorPayload) -> Result<()>

pub async fn write_session_started( &mut self, payload: &SessionStartedPayload, ) -> Result<()>

pub async fn write_proxy_submit( &mut self, payload: &ProxySubmitPayload, ) -> Result<()>

pub async fn write_proxy_cancel(&mut self, proxy_id: &str) -> Result<()>

pub async fn write_proxy_stdout_chunk( &mut self, payload: &ProxyChunkPayload, ) -> Result<()>

pub async fn write_proxy_stderr_chunk( &mut self, payload: &ProxyChunkPayload, ) -> Result<()>

pub async fn write_proxy_completed( &mut self, payload: &ProxyCompletedPayload, ) -> Result<()>

pub async fn write_proxy_rejected( &mut self, payload: &ProxyRejectedPayload, ) -> Result<()>