Struct AuthClient 

#[non_exhaustive]
pub struct AuthClient<C> {
    pub http_client: C,
    pub auth_manager: Arc<Mutex<AuthorizationManager>>,
}

Available on crate feature auth and (crate features client or server) only.

HTTP client with OAuth 2.0 authorization

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

http_client: C

auth_manager: Arc<Mutex<AuthorizationManager>>

Implementations

impl<C> AuthClient<C>

pub fn new(http_client: C, auth_manager: AuthorizationManager) -> Self

Create a new authorized HTTP client

impl<C> AuthClient<C>

pub fn get_access_token( &self, ) -> impl Future<Output = Result<String, AuthError>> + Send

Trait Implementations

impl<C: Clone> Clone for AuthClient<C>

fn clone(&self) -> AuthClient<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for AuthClient<C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C> StreamableHttpClient for AuthClient<C>

where C: StreamableHttpClient + Send + Sync,

Available on crate feature transport-streamable-http-client only.

type Error = <C 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<Self::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<BoxStream<'static, Result<Sse, Error>>, StreamableHttpError<Self::Error>>

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

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

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

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 post_message_with_max_sse_event_size( &self, uri: Arc<str>, message: ClientJsonRpcMessage, session_id: Option<Arc<str>>, auth_token: Option<String>, custom_headers: HashMap<HeaderName, HeaderValue>, max_sse_event_size: usize, ) -> Result<StreamableHttpPostResponse, StreamableHttpError<Self::Error>>

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