faktory 0.13.1

API bindings for the language-agnostic Faktory work server
Documentation 
1
2
3
4
5
6
7
8
9
10

use tokio::io::{AsyncBufRead, AsyncWrite};

use crate::Reconnect;

/// A duplex buffered stream to the Faktory service.
pub trait Connection: AsyncWrite + AsyncBufRead + Unpin + Send + Reconnect {}

impl<T> Connection for T where T: AsyncWrite + AsyncBufRead + Unpin + Send + Reconnect {}

pub type BoxedConnection = Box<dyn Connection>;