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 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.