Struct interledger_stream::StreamReceiverService

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

An IncomingService 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, A> StreamReceiverService<S, A> where
    S: IncomingService<A>,
    A: Account, 

pub fn new(
    server_secret: &[u8; 32],
    ildcp_response: IldcpResponse,
    next: S
) -> Self

pub fn without_ildcp(server_secret: &[u8; 32], next: S) -> Self

For creating a receiver service before the ILDCP details have been received

pub fn set_ildcp(&self, ildcp_response: IldcpResponse)

Trait Implementations

impl<S: Clone + IncomingService<A>, A: Clone + Account> Clone for StreamReceiverService<S, A>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S, A> IncomingService<A> for StreamReceiverService<S, A> where
    S: IncomingService<A>,
    A: Account, 

type Future = BoxedIlpFuture

fn handle_request(&mut self, request: IncomingRequest<A>) -> Self::Future