Struct AsyncLoadBalancer 

pub struct AsyncLoadBalancer<I: Send + Clone + 'static, O: Send + Clone + 'static> {
    pub output_rx: Receiver<O>,
    pub input_tx: Sender<I>,
    pub handles: Vec<JoinHandle<()>>,
}

An asynchronous load balancer for distributing tasks across multiple workers, using tokio! Please remember that outputs might not be 1/1 timewise with inputs. Inputs ordered A,B,C could come out ordered A,C,B!

Example:

let mut lb: LoadBalancer<i32, i32> = LoadBalancer::new(100, 4, |x| {Box::pin(async move {x * 2})});
for i in 0..100 {
   lb.input_tx.send(i).await.unwrap();
}
for i in 0..100 {
   let result = lb.recv().await.unwrap();
   assert_eq!(result % 2, 0);
   println!("Received: {}", result);
}

Fields

output_rx: Receiver<O>

input_tx: Sender<I>

handles: Vec<JoinHandle<()>>

Implementations

impl<I, O> AsyncLoadBalancer<I, O>

where I: Send + Clone + 'static, O: Send + Clone + 'static,

pub fn new<F>(channel_limits: usize, worker_count: usize, task: F) -> Self

where F: Fn(I) -> Pin<Box<dyn Future<Output = O> + Send>> + Send + Sync + 'static,

pub async fn recv(&mut self) -> Option<O>

Trait Implementations

impl<I, O> Drop for AsyncLoadBalancer<I, O>

where I: Send + Clone + 'static, O: Send + Clone + 'static,

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.