Enum wrpc_interface_http::Scheme
source · pub enum Scheme {
HTTP,
HTTPS,
Other(String),
}
Variants§
Trait Implementations§
source§impl EncodeSync for Scheme
impl EncodeSync for Scheme
source§impl PartialEq for Scheme
impl PartialEq for Scheme
source§impl Receive for Scheme
impl Receive for Scheme
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>>
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 Eq for Scheme
impl StructuralPartialEq for Scheme
Auto Trait Implementations§
impl RefUnwindSafe for Scheme
impl Send for Scheme
impl Sync for Scheme
impl Unpin for Scheme
impl UnwindSafe for Scheme
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<T> Encode for Twhere
T: EncodeSync + Send,
impl<T> Encode for Twhere
T: EncodeSync + Send,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§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<R, Ctx> ReceiveContext<Ctx> for R
impl<R, Ctx> ReceiveContext<Ctx> for R
fn receive_context<'life0, 'life1, 'async_trait, T>( _cx: &'life0 Ctx, payload: impl Buf + Send + 'async_trait + 'static, 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>), Error>> + Send + 'async_trait>>
fn receive_context_sync<'life0, 'life1, 'async_trait>(
cx: &'life0 Ctx,
payload: impl Buf + Send + 'async_trait + 'static,
rx: &'life1 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,
'life1: 'async_trait,
Self: Send + 'async_trait,
source§fn receive_list_context<'life0, 'life1, 'async_trait, T>(
cx: &'life0 Ctx,
payload: impl Buf + Send + 'async_trait + 'static,
rx: &'life1 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>), Error>> + Send + 'async_trait>>
fn receive_list_context<'life0, 'life1, 'async_trait, T>( cx: &'life0 Ctx, payload: impl Buf + Send + 'async_trait + 'static, rx: &'life1 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>), Error>> + Send + 'async_trait>>
Receive a list
source§fn receive_tuple_context<'a, 'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'static,
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>), Error>> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: Send + 'async_trait,
fn receive_tuple_context<'a, 'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'static,
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>), Error>> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: Send + 'async_trait,
Receive a tuple