frpc-lib 0.1.0

Library for Fluid RPC to dynamically invoke gRPC services
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::error::Error;

use futures::channel::mpsc::UnboundedSender;

use crate::{
    invoker::invoker_error::InvokerError,
    stream::{fluid_error::FluidError, fluid_stream_event::FluidStreamEvent},
};

// This is really just to clean up the code in the invoker...
pub fn send_invoker_error(
    tx: &mut UnboundedSender<FluidStreamEvent>,
    err: InvokerError,
) -> Box<dyn Error + Send + Sync> {
    match tx.unbounded_send(FluidStreamEvent::Error(FluidError::new(Box::new(
        err.clone(),
    )))) {
        Ok(_) => Box::new(err),
        Err(e) => Box::new(e),
    }
}