Struct interledger_btp::BtpService

pub struct BtpService<I, O, A: Account> { /* fields omitted */ }

Methods

impl<I, O, A> BtpService<I, O, A> where
    I: IncomingService<A> + Clone + Send + 'static,
    O: OutgoingService<A> + Clone,
    A: BtpAccount + 'static, 

pub fn close(&self)

Close all of the open WebSocket connections

Trait Implementations

impl<I: Clone, O: Clone, A: Clone + Account> Clone for BtpService<I, O, A>

fn clone(&self) -> BtpService<I, O, A>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I, O, A> OutgoingService<A> for BtpService<I, O, A> where
    O: OutgoingService<A> + Clone + Send + 'static,
    A: BtpAccount + 'static, 

type Future = BoxedIlpFuture

fn send_request(&mut self, request: OutgoingRequest<A>) -> Self::Future

Send an outgoing request to one of the open connections.

If there is no open connection for the Account specified in request.to, the request will be passed through to the next handler.

fn wrap<F, R>(self, f: F) -> WrappedService<F, Self, A> where
    F: Fn(OutgoingRequest<A>, Self) -> R,
    R: Future<Item = Fulfill, Error = Reject> + Send + 'static,
    Self: Clone, 

Wrap the given service such that the provided function will be called to handle each request. That function can return immediately, modify the request before passing it on, and/or handle the result of calling the inner service.