pop-launcher 1.2.7

Library for writing plugins and frontends for pop-launcher
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

// Copyright 2021 System76 <info@system76.com>
// SPDX-License-Identifier: MPL-2.0

use futures::{Stream, StreamExt};
use serde::Deserialize;
use tokio::io::{AsyncBufReadExt, AsyncRead};

/// stdin with [`AsyncWrite`] support
#[must_use]
#[inline]
pub fn async_stdin() -> tokio::io::Stdin {
    tokio::io::stdin()
}

/// stdout with [`AsyncWrite`] support
#[must_use]
#[inline]
pub fn async_stdout() -> tokio::io::Stdout {
    tokio::io::stdout()
}

/// Creates a stream that parses JSON input line-by-line
pub fn json_input_stream<I, S>(input: I) -> impl Stream<Item = serde_json::Result<S>> + Unpin + Send
where
    I: AsyncRead + Unpin + Send,
    S: for<'a> Deserialize<'a>,
{
    let line_reader = tokio::io::BufReader::new(input).lines();
    tokio_stream::wrappers::LinesStream::new(line_reader)
        .take_while(|x| futures::future::ready(x.is_ok()))
        .map(Result::unwrap)
        .map(|line| serde_json::from_str::<S>(&line))
}