Struct interledger_btp::BtpOutgoingService

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

A container for BTP/WebSocket connections that implements OutgoingService for sending outgoing ILP Prepare packets over one of the connected BTP connections.

Methods

impl<O, A> BtpOutgoingService<O, A> where
    O: OutgoingService<A> + Clone,
    A: BtpAccount + 'static, 

pub fn new(ilp_address: Address, next: O) -> Self

pub fn close(&self)

Close all of the open WebSocket connections

pub fn handle_incoming<I>(self, incoming_handler: I) -> BtpService<I, O, A> where
    I: IncomingService<A> + Clone + Send + 'static, 

Convert this BtpOutgoingService into a bidirectional BtpService by adding a handler for incoming requests. This will automatically pull all incoming Prepare packets from the channel buffer and call the IncomingService with them.

Trait Implementations

impl<O: Clone, A: Clone + Account> Clone for BtpOutgoingService<O, A> where
    A::AccountId: Clone, 

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<O, A> OutgoingService<A> for BtpOutgoingService<O, A> where
    O: OutgoingService<A> + Clone,
    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.