pub fn start(&self) -> impl Stream<Item = Result<tty::TtyChunk>> + 'docker {
        // We must take ownership of the docker reference to not needlessly tie the stream to the
        // lifetime of `self`.
        let docker = self.docker;
        // We convert `self.id` into the (owned) endpoint outside of the stream to not needlessly
        // tie the stream to the lifetime of `self`.
        let endpoint = format!("/exec/{}/start", &self.id);
        Box::pin(
            async move {
                let stream = Box::pin(docker.stream_post(
                    endpoint,
                    Some(("{}".into(), mime::APPLICATION_JSON)),
                    None::<iter::Empty<_>>,
                ));

                Ok(tty::decode(stream))
            }
            .try_flatten_stream(),
        )
    }
/// Starts this exec instance returning a multiplexed tty stream
Starts this exec instance returning a multiplexed tty stream
Starts this exec instance returning a multiplexed tty stream
pub fn start(&self) -> impl Stream<Item = Result<tty::TtyChunk>> + 'docker {
        // We must take ownership of the docker reference to not needlessly tie the stream to the
        // lifetime of `self`.
        let docker = self.docker;
        // We convert `self.id` into the (owned) endpoint outside of the stream to not needlessly
        // tie the stream to the lifetime of `self`.
        let endpoint = format!("/exec/{}/start", &self.id);
        Box::pin(
            async move {
                let stream = Box::pin(docker.stream_post(
                    endpoint,
                    Some(("{}".into(), mime::APPLICATION_JSON)),
                    None::<iter::Empty<_>>,
                ));
                Ok(tty::decode(stream))
            }
            .try_flatten_stream(),
        )
    }
pub fn start ( & self ) -> impl Stream < Item = Result < tty :: TtyChunk > > + ' docker { // We must take ownership of the docker reference to not needlessly tie the stream to the // lifetime of `self`. let docker = self . docker ; // We convert `self.id` into the (owned) endpoint outside of the stream to not needlessly // tie the stream to the lifetime of `self`. let endpoint = format ! ( " " self id ) ; Box :: pin ( async move { let stream = Box :: pin ( docker . stream_post ( endpoint , Some ( ( " " . into ( ) , mime :: APPLICATION_JSON ) ) , None :: < iter :: Empty < _ > > , ) ) ; Ok ( tty :: decode ( stream ) ) } . try_flatten_stream ( ) , ) }
Starts this exec instance returning a multiplexed tty stream
Starts this exec instance returning a multiplexed tty stream
&self
&self