Struct UdpService 

pub struct UdpService { /* private fields */ }

Bind a UDP socket and invoke handler for each datagram until shutdown.

Implementations

impl UdpService

pub fn new<F, Fut>(addr: SocketAddr, handler: F) -> Self

where F: Fn(SocketAddr, Vec<u8>, Arc<UdpSocket>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

pub fn echo(addr: SocketAddr) -> Self

Trait Implementations

impl BackgroundService for UdpService

fn name(&self) -> &str

fn run( self: Box<Self>, _state: Arc<StateMap>, shutdown: Shutdown, ) -> BoxFuture<()>

Run until shutdown becomes true (or the future completes).