Struct SseMessageHandler 

pub struct SseMessageHandler { /* private fields */ }

HTTP POST message handler for SSE transport

Implementations

impl SseMessageHandler

pub fn new() -> Self

Create a new message handler

pub fn with_max_message_size(self, max_message_size: usize) -> Self

Set maximum accepted JSON-RPC request size for POST messages.

pub fn with_max_pending_responses(self, max_pending_responses: usize) -> Self

Set maximum number of queued POST messages.

pub fn with_max_pending_response_bytes( self, max_pending_response_bytes: usize, ) -> Self

Set maximum aggregate bytes queued by POST messages.

pub fn handle_message(&self, json: &str) -> Result<(), String>

Handle an incoming POST message

pub fn take_responses(&self) -> Vec<String>

Get pending responses

pub fn has_pending(&self) -> bool

Check if there are pending responses

Trait Implementations

impl Default for SseMessageHandler

fn default() -> Self

Returns the “default value” for a type.