Enum wrpc_interface_http::Scheme
source · pub enum Scheme {
HTTP,
HTTPS,
Other(String),
}
Variants§
Trait Implementations§
source§impl PartialEq for Scheme
impl PartialEq for Scheme
source§impl<'a> Receive<'a> for Scheme
impl<'a> Receive<'a> for Scheme
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 Scheme
impl Subscribe for Scheme
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 Scheme
impl StructuralPartialEq for Scheme
Auto Trait Implementations§
impl Freeze for Scheme
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<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