graphile_worker_database 0.1.5

Database driver abstraction for graphile_worker
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

use std::pin::Pin;

use futures::Stream;

use crate::DbError;

pub type NotificationStream = Pin<Box<dyn Stream<Item = Result<Notification, DbError>> + Send>>;

#[derive(Clone, Debug)]
pub struct Notification {
    pub channel: String,
    pub payload: String,
}