komodo_client 2.1.1

Client for the Komodo build and deployment system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use futures_util::{Stream, StreamExt, TryStreamExt};

pub struct TerminalStreamResponse(pub reqwest::Response);

impl TerminalStreamResponse {
  pub fn into_line_stream(
    self,
  ) -> impl Stream<Item = Result<String, tokio_util::codec::LinesCodecError>>
  {
    tokio_util::codec::FramedRead::new(
      tokio_util::io::StreamReader::new(
        self.0.bytes_stream().map_err(std::io::Error::other),
      ),
      tokio_util::codec::LinesCodec::new(),
    )
    .map(|line| line.map(|line| line + "\n"))
  }
}