Struct Feed 

pub struct Feed { /* private fields */ }

One websocket connection, kept open. Dropping the feed closes it.

Implementations

impl Feed

pub fn start(session: Session) -> Feed

Connects to the session’s network on the current tokio runtime.

pub fn start_at(url: impl Into<String>, session: Session) -> Feed

Connects to url instead of the session’s network: a proxy, or a test.

pub async fn subscribe( &self, subscription: Subscription, ) -> Result<(), FeedError>

Wants subscription from now on, across reconnects. Refused past the session’s limits.

pub fn unsubscribe(&self, subscription: Subscription) -> Result<(), FeedError>

pub async fn post(&self, request: Post) -> Result<u64, FeedError>

Sends an info request or a signed action over the socket, and gives its id; the answer arrives as crate::live::Frame::Post with the same id.

pub async fn next(&mut self) -> Option<Event>

The next event; None once the feed has stopped.

pub async fn next_with_text(&mut self) -> Option<(Event, Option<String>)>

The next event, and for a frame, read or not, the text it arrived as: for a program that still reads some channels its own way. None once the feed has stopped.

pub fn close(self)

Closes the socket and stops.

Trait Implementations

impl Drop for Feed

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.