Struct BodyCappedHttpClient 

pub struct BodyCappedHttpClient { /* private fields */ }

Implementations

impl BodyCappedHttpClient

pub fn new( inner: Client, json_max_bytes: usize, sse_event_max_bytes: usize, ) -> BodyCappedHttpClient

pub fn default_with_caps( json_max_bytes: usize, sse_event_max_bytes: usize, ) -> BodyCappedHttpClient

Trait Implementations

impl Clone for BodyCappedHttpClient

fn clone(&self) -> BodyCappedHttpClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl StreamableHttpClient for BodyCappedHttpClient

type Error = Error

async fn post_message( &self, uri: Arc<str>, message: JsonRpcMessage<ClientRequest, ClientResult, ClientNotification>, session_id: Option<Arc<str>>, auth_token: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, ) -> Result<StreamableHttpPostResponse, StreamableHttpError<<BodyCappedHttpClient as StreamableHttpClient>::Error>>

async fn delete_session( &self, uri: Arc<str>, session_id: Arc<str>, auth_token: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, ) -> Result<(), StreamableHttpError<<BodyCappedHttpClient as StreamableHttpClient>::Error>>

async fn get_stream( &self, uri: Arc<str>, session_id: Option<Arc<str>>, last_event_id: Option<String>, auth_token: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, ) -> Result<Pin<Box<dyn Stream<Item = Result<Sse, Error>> + Send>>, StreamableHttpError<<BodyCappedHttpClient as StreamableHttpClient>::Error>>

Open an SSE stream, optionally scoped to a legacy session.

fn post_message_with_max_sse_event_size( &self, uri: Arc<str>, message: JsonRpcMessage<ClientRequest, ClientResult, ClientNotification>, session_id: Option<Arc<str>>, auth_header: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, _max_sse_event_size: usize, ) -> impl Future<Output = Result<StreamableHttpPostResponse, StreamableHttpError<Self::Error>>> + Send

Send a message while enforcing a maximum raw SSE event size.

fn get_stream_with_max_sse_event_size( &self, uri: Arc<str>, session_id: Option<Arc<str>>, last_event_id: Option<String>, auth_header: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, _max_sse_event_size: usize, ) -> impl Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Sse, Error>> + Send>>, StreamableHttpError<Self::Error>>> + Send

Open an SSE stream while enforcing a maximum raw event size.