Struct interledger::stream::StreamReceiverService

pub struct StreamReceiverService<S, O, A> where
    A: Account,
    O: OutgoingService<A>,  { /* fields omitted */ }

An OutgoingService that fulfills incoming STREAM packets.

Note this does not maintain STREAM state, but instead fulfills all incoming packets to collect the money.

This does not currently support handling data sent via STREAM.

Methods

impl<S, O, A> StreamReceiverService<S, O, A> where
    A: Account,
    O: OutgoingService<A>,
    S: StreamNotificationsStore<Account = A>, 

pub fn new(
    server_secret: Bytes,
    store: S,
    next: O
) -> StreamReceiverService<S, O, A>

Trait Implementations

impl<S, O, A> OutgoingService<A> for StreamReceiverService<S, O, A> where
    A: Account,
    O: OutgoingService<A>,
    S: StreamNotificationsStore + Send + Sync + 'static + Clone, 

type Future = Box<dyn Future<Error = Reject, Item = Fulfill> + 'static + Send>

fn send_request(
    &mut self,
    request: OutgoingRequest<A>
) -> <StreamReceiverService<S, O, A> as OutgoingService<A>>::Future

Try fulfilling the request if it is for this STREAM server or pass it to the next outgoing handler if not.

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.

impl<S, O, A> Clone for StreamReceiverService<S, O, A> where
    A: Clone + Account,
    O: Clone + OutgoingService<A>,
    S: Clone, 

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

Returns a copy of the value.

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

Performs copy-assignment from source.