Struct BodyCappedHttpClient 

pub struct BodyCappedHttpClient { /* private fields */ }

Implementations

impl BodyCappedHttpClient

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

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

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: ClientJsonRpcMessage, session_id: Option<Arc<str>>, auth_token: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, ) -> Result<StreamableHttpPostResponse, StreamableHttpError<Self::Error>>

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

async fn get_stream( &self, uri: Arc<str>, session_id: Arc<str>, last_event_id: Option<String>, auth_token: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, ) -> Result<BoxStream<'static, Result<Sse, SseError>>, StreamableHttpError<Self::Error>>