Struct SubscriptionInner 

pub(crate) struct SubscriptionInner {
    pub config: SubscriptionConfig,
    pub state: SubscriptionState,
    pub stream_position: Option<StreamPosition>,
    pub event_tx: Sender<SubscriptionEvent>,
}

Fields

config: SubscriptionConfig

state: SubscriptionState

stream_position: Option<StreamPosition>

event_tx: Sender<SubscriptionEvent>

Implementations

impl SubscriptionInner

pub(crate) fn new( config: SubscriptionConfig, event_tx: Sender<SubscriptionEvent>, ) -> Self

pub(crate) fn on_subscribed(&mut self, result: &SubscribeResult)

pub(crate) fn update_position(&mut self, offset: u64)

pub(crate) fn build_subscribe_request(&self, recover: bool) -> SubscribeRequest