apalis-board-api 1.0.0-rc.7

HTTP utilities for managing apalis task queues.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::{
    pin::Pin,
    task::{Context, Poll},
};

use apalis_board_types::LogEntry;
use futures::{
    Stream, StreamExt,
    channel::mpsc::{Receiver, TryRecvError},
};

/// A client that receives log entries from a server-sent events (SSE) stream.
#[derive(Debug)]
pub struct Client(pub(crate) Receiver<LogEntry>);

impl Stream for Client {
    type Item = Result<LogEntry, TryRecvError>;

    fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
        self.0.poll_next_unpin(cx).map(|c| Ok(c).transpose())
    }
}