Enum wrpc_interface_http::Method
source · pub enum Method {
Get,
Head,
Post,
Put,
Delete,
Connect,
Options,
Trace,
Patch,
Other(String),
}
Variants§
Trait Implementations§
source§impl PartialEq for Method
impl PartialEq for Method
source§impl<'a> Receive<'a> for Method
impl<'a> Receive<'a> for Method
fn receive<'life0, 'async_trait, T>( payload: impl 'async_trait + Buf + Send + 'a, 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 + 'a>)>> + Send + 'async_trait>>
fn receive_sync<'life0, 'async_trait>(
payload: impl Buf + Send + 'async_trait + 'a,
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 + 'a>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: Send + 'async_trait,
source§impl Subscribe for Method
impl Subscribe for Method
fn subscribe<T>( _subscriber: &T, _subject: <T as Subscriber>::Subject ) -> impl Future<Output = Result<Option<AsyncSubscription<<T as Subscriber>::Stream>>, <T as Subscriber>::SubscribeError>> + Send
impl Eq for Method
impl StructuralPartialEq for Method
Auto Trait Implementations§
impl Freeze for Method
impl RefUnwindSafe for Method
impl Send for Method
impl Sync for Method
impl Unpin for Method
impl UnwindSafe for Method
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<'a, R, Ctx> ReceiveContext<'a, Ctx> for R
impl<'a, R, Ctx> ReceiveContext<'a, Ctx> for R
fn receive_context<'life0, 'life1, 'async_trait, T>( _cx: &'life0 Ctx, payload: impl Buf + Send + 'async_trait + 'a, rx: &'life1 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait), sub: Option<AsyncSubscription<T>> ) -> Pin<Box<dyn Future<Output = Result<(R, Box<dyn Buf + Send + 'a>), Error>> + Send + 'async_trait>>
fn receive_context_sync(
cx: &'a Ctx,
payload: impl Buf + Send + 'a,
rx: &'a mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'a)
) -> impl Future<Output = Result<(Self, Box<dyn Buf + Send + 'a>), Error>> + Send + 'awhere
Self: 'a,
source§fn receive_list_context<T>(
cx: &Ctx,
payload: impl Buf + Send + 'a,
rx: &mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin),
sub: Option<AsyncSubscription<T>>
) -> impl Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send
fn receive_list_context<T>( cx: &Ctx, payload: impl Buf + Send + 'a, rx: &mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin), sub: Option<AsyncSubscription<T>> ) -> impl Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send
Receive<’a> a list
source§fn receive_tuple_context<'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'a,
rx: &'life0 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait),
sub: Option<AsyncSubscription<T>>
) -> Pin<Box<dyn Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: 'async_trait,
fn receive_tuple_context<'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'a,
rx: &'life0 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait),
sub: Option<AsyncSubscription<T>>
) -> Pin<Box<dyn Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: 'async_trait,
Receive<’a> a tuple