Struct SubscribeRequest 

pub struct SubscribeRequest {
    pub filter: SubscriptionFilter,
    pub include_history: bool,
    pub from_lsn: Option<u64>,
    pub max_inflight: u32,
    pub act_as: Option<ActAs>,
}

SUBSCRIBE (0x0030). Opens a long-lived push stream; the server emits SUBSCRIBE_EVENT (0x00B0) frames on the subscription’s stream id until the client sends UNSUBSCRIBE (0x0031).

Fields

filter: SubscriptionFilter

include_history: bool

from_lsn: Option<u64>

max_inflight: u32

act_as: Option<ActAs>

Effective identity this subscription runs as, on behalf of the authenticated connection principal. None (the common case, and omitted on the wire) means the op runs as the connection’s own key-bound identity.

Trait Implementations

impl Clone for SubscribeRequest

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SubscribeRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscribeRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SubscribeRequest

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for SubscribeRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SubscribeRequest