[−][src]Struct interledger_stream::StreamReceiverService
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
S: StreamNotificationsStore<Account = A>,
O: OutgoingService<A>,
A: Account,
[src]
S: StreamNotificationsStore<Account = A>,
O: OutgoingService<A>,
A: Account,
Trait Implementations
impl<S: Clone, O: Clone + OutgoingService<A>, A: Clone + Account> Clone for StreamReceiverService<S, O, A>
[src]
fn clone(&self) -> StreamReceiverService<S, O, A>
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<S, O, A> OutgoingService<A> for StreamReceiverService<S, O, A> where
S: StreamNotificationsStore + Send + Sync + 'static + Clone,
O: OutgoingService<A>,
A: Account,
[src]
S: StreamNotificationsStore + Send + Sync + 'static + Clone,
O: OutgoingService<A>,
A: Account,
type Future = BoxedIlpFuture
fn send_request(&mut self, request: OutgoingRequest<A>) -> Self::Future
[src]
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,
[src]
F: Fn(OutgoingRequest<A>, Self) -> R,
R: Future<Item = Fulfill, Error = Reject> + Send + 'static,
Self: Clone,
Auto Trait Implementations
impl<S, O, A> Send for StreamReceiverService<S, O, A> where
O: Send,
S: Send,
O: Send,
S: Send,
impl<S, O, A> Sync for StreamReceiverService<S, O, A> where
A: Sync,
O: Sync,
S: Sync,
A: Sync,
O: Sync,
S: Sync,
impl<S, O, A> Unpin for StreamReceiverService<S, O, A> where
A: Unpin,
O: Unpin,
S: Unpin,
A: Unpin,
O: Unpin,
S: Unpin,
impl<S, O, A> UnwindSafe for StreamReceiverService<S, O, A> where
A: UnwindSafe,
O: UnwindSafe,
S: UnwindSafe,
A: UnwindSafe,
O: UnwindSafe,
S: UnwindSafe,
impl<S, O, A> RefUnwindSafe for StreamReceiverService<S, O, A> where
A: RefUnwindSafe,
O: RefUnwindSafe,
S: RefUnwindSafe,
A: RefUnwindSafe,
O: RefUnwindSafe,
S: RefUnwindSafe,
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From<T> for T
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,