Struct wrpc_interface_http::OutgoingRequest

pub struct OutgoingRequest<T> {
    pub body: T,
    pub method: Method,
    pub path_with_query: Option<String>,
    pub scheme: Option<Scheme>,
    pub authority: Option<String>,
    pub headers: Fields,
}

Fields

body: T

method: Method

path_with_query: Option<String>

scheme: Option<Scheme>

authority: Option<String>

headers: Fields

Trait Implementations

impl<T> Encode for OutgoingRequest<T>

where T: Stream<Item = StreamItem<Bytes, Option<Fields>>> + Send + 'static,

fn encode<'life0, 'async_trait>( self, payload: &'life0 mut (impl 'async_trait + BufMut + Send) ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncValue>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl Receive for OutgoingRequest<Box<dyn Stream<Item = Result<StreamItem<Bytes, Option<Fields>>>> + Send + Unpin>>

fn receive<'life0, 'async_trait, T>( payload: impl 'async_trait + Buf + Send + 'static, rx: &'life0 mut (impl 'async_trait + Stream<Item = Result<Bytes>> + Send + Sync + Unpin), sub: Option<AsyncSubscription<T>> ) -> Pin<Box<dyn Future<Output = Result<(Self, Box<dyn Buf + Send>)>> + Send + 'async_trait>>

where T: Stream<Item = Result<Bytes>> + Send + Sync + Unpin + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn receive_sync<'life0, 'async_trait>( payload: impl Buf + Send + 'async_trait + 'static, rx: &'life0 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait) ) -> Pin<Box<dyn Future<Output = Result<(Self, Box<dyn Buf + Send>), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

impl Subscribe for OutgoingRequest<Box<dyn Stream<Item = Result<StreamItem<Bytes, Option<Fields>>>> + Send + Unpin>>

fn subscribe<'life0, 'async_trait, T>( subscriber: &'life0 T, subject: T::Subject ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncSubscription<T::Stream>>, T::SubscribeError>> + Send + 'async_trait>>

where T: 'async_trait + Subscriber + Send + Sync, 'life0: 'async_trait,