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