Enum gapi_grpc::google::cloud::pubsublite::v1::subscribe_request::Request[][src]

pub enum Request {
    Initial(InitialSubscribeRequest),
    Seek(SeekRequest),
    FlowControl(FlowControlRequest),
}

The type of request this is.

Variants

Initial(InitialSubscribeRequest)

Initial request on the stream.

Seek(SeekRequest)

Request to update the stream’s delivery cursor.

FlowControl(FlowControlRequest)

Request to grant tokens to the server,

Implementations

impl Request[src]

pub fn encode<B>(&self, buf: &mut B) where
    B: BufMut
[src]

pub fn merge<B>(
    field: &mut Option<Request>,
    tag: u32,
    wire_type: WireType,
    buf: &mut B,
    ctx: DecodeContext
) -> Result<(), DecodeError> where
    B: Buf
[src]

pub fn encoded_len(&self) -> usize[src]

Trait Implementations

impl Clone for Request[src]

impl Debug for Request[src]

impl PartialEq<Request> for Request[src]

impl StructuralPartialEq for Request[src]

Auto Trait Implementations

impl RefUnwindSafe for Request

impl Send for Request

impl Sync for Request

impl Unpin for Request

impl UnwindSafe for Request

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> IntoRequest<T> for T[src]

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 
[src]

impl<T> WithSubscriber for T[src]