pub struct CoAPRunner<'a, const CONCURRENT_REQUESTS: usize> { /* private fields */ }
Expand description
Access to the server side of a CoAPShared
This needs to be [.run()
] both in order to serve peers and to make progress on any
requests issued through the CoAPRuntimeClient on the same Shared.
Implementations§
Source§impl<'a, const CONCURRENT_REQUESTS: usize> CoAPRunner<'a, CONCURRENT_REQUESTS>
impl<'a, const CONCURRENT_REQUESTS: usize> CoAPRunner<'a, CONCURRENT_REQUESTS>
Sourcepub async fn run<Socket, Handler, RandomSource>(
&self,
socket: &mut Socket,
handler: &mut Handler,
rand: &mut RandomSource,
) -> Result<(), Socket::Error>
pub async fn run<Socket, Handler, RandomSource>( &self, socket: &mut Socket, handler: &mut Handler, rand: &mut RandomSource, ) -> Result<(), Socket::Error>
Service the socket, sending any incoming requests to the handler, simultaneously taking care to interact with the structures shared with the client parts to send out the requests and file back the responses.
If any error occurs on the socket, this terminates.
Auto Trait Implementations§
impl<'a, const CONCURRENT_REQUESTS: usize> Freeze for CoAPRunner<'a, CONCURRENT_REQUESTS>
impl<'a, const CONCURRENT_REQUESTS: usize> !RefUnwindSafe for CoAPRunner<'a, CONCURRENT_REQUESTS>
impl<'a, const CONCURRENT_REQUESTS: usize> !Send for CoAPRunner<'a, CONCURRENT_REQUESTS>
impl<'a, const CONCURRENT_REQUESTS: usize> !Sync for CoAPRunner<'a, CONCURRENT_REQUESTS>
impl<'a, const CONCURRENT_REQUESTS: usize> Unpin for CoAPRunner<'a, CONCURRENT_REQUESTS>
impl<'a, const CONCURRENT_REQUESTS: usize> !UnwindSafe for CoAPRunner<'a, CONCURRENT_REQUESTS>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more