Skip to main content

model_events

cratestack::rpc

Function model_events 

Source 
pub fn model_events<T>(
    receiver: Pin<Box<dyn Stream<Item = BackplaneMessage> + Send>>,
) -> impl Stream<Item = Result<FeedEvent<T>, CratestackError>> + Send + 'static
where
    T: DeserializeOwned + Send + 'static,
Expand description

The model events published on a backplane channel, decoded. A payload that does not decode (a replica on another schema version mid-deploy) ends the feed: the client refetches rather than miss an event.