Struct EchoService

pub struct EchoService { /* private fields */ }

An async service which echoes the incoming bytes back on the same stream.

Example

use rama_core::{error::BoxError, Context, Service};
use rama_net::stream::service::EchoService;

let service = EchoService::new();

let bytes_copied = service.serve(Context::default(), stream).await?;

Implementations

impl EchoService

pub const fn new() -> EchoService

Creates a new EchoService,

Trait Implementations

impl Clone for EchoService

fn clone(&self) -> EchoService

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EchoService

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

Formats the value using the given formatter.

impl Default for EchoService

fn default() -> EchoService

Returns the “default value” for a type.

impl<T, S> Service<T, S> for EchoService

where T: Send + Sync + 'static, S: Stream + 'static,

type Response = u64

The type of response returned by the service.

type Error = Box<dyn Error + Sync + Send>

The type of error returned by the service.

async fn serve( &self, _ctx: Context<T>, stream: S, ) -> Result<<EchoService as Service<T, S>>::Response, <EchoService as Service<T, S>>::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.