Struct Subscription 

pub struct Subscription { /* private fields */ }

A handle to an active MEV-Share SSE connection.

Returned by [Client::subscribe]. Call into_stream to begin consuming events.

Implementations

impl Subscription

pub fn into_stream(self) -> EventStream

Converts this subscription into an async Stream of Events.

The stream will:

• Automatically skip SSE keepalive pings sent every 15 seconds
• Deserialize each event’s JSON payload into a typed Event
• Yield Error::Deserialize for malformed payloads without terminating the stream
• Yield Error::Stream for underlying SSE transport errors

Examples

use mevshare::Client;
use futures::StreamExt;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let sub = Client::builder().build().subscribe().await?;
    let mut stream = sub.into_stream();

    while let Some(event) = stream.next().await {
        match event {
            Ok(ev) => println!("{ev:#?}"),
            Err(e) => eprintln!("stream error: {e}"),
        }
    }
    Ok(())
}