interledger-service 0.4.0

The core abstraction for the Interledger.rs implementation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use crate::*;
use tracing_futures::{Instrument, Instrumented};

// TODO see if we can replace this with the tower tracing later
impl<IO, A> IncomingService<A> for Instrumented<IO>
where
    IO: IncomingService<A> + Clone,
    A: Account,
{
    type Future = Instrumented<IO::Future>;

    fn handle_request(&mut self, request: IncomingRequest<A>) -> Self::Future {
        let span = self.span().clone();
        let _enter = span.enter();
        self.inner_mut().handle_request(request).in_current_span()
    }
}

impl<IO, A> OutgoingService<A> for Instrumented<IO>
where
    IO: OutgoingService<A> + Clone,
    A: Account,
{
    type Future = Instrumented<IO::Future>;

    fn send_request(&mut self, request: OutgoingRequest<A>) -> Self::Future {
        let span = self.span().clone();
        let _enter = span.enter();
        self.inner_mut().send_request(request).in_current_span()
    }
}