Struct AsyncHttpClientService

Source

pub struct AsyncHttpClientService { /* private fields */ }

Expand description

The registered service wrapper (Java AsyncHttpClient implements TypedLambdaFunction; registered by the app starter at 500 instances). Holds the platform it is registered on so its manual replies route to that platform’s temporary.inbox reply listener.

AsyncHttpClientService

Struct AsyncHttpClientService Copy item path

Implementations§

impl AsyncHttpClientService

pub fn new(platform: &Platform) -> Self

Trait Implementations§

impl ComposableFunction for AsyncHttpClientService

fn handle_event<'life0, 'async_trait>( &'life0 self, headers: HashMap<String, String>, input: EventEnvelope, _instance: usize, ) -> Pin<Box<dyn Future<Output = Result<EventEnvelope, AppError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Auto Trait Implementations§

impl Freeze for AsyncHttpClientService

impl RefUnwindSafe for AsyncHttpClientService

impl Send for AsyncHttpClientService

impl Sync for AsyncHttpClientService

impl Unpin for AsyncHttpClientService

impl UnsafeUnpin for AsyncHttpClientService

impl UnwindSafe for AsyncHttpClientService

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

Struct AsyncHttpClientService

fn handle_event<'life0, 'async_trait>( &'life0 self, headers: HashMap<String, String>, input: EventEnvelope, _instance: usize, ) -> Pin<Box<dyn Future<Output = Result<EventEnvelope, AppError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,