Struct actix_net::stream::TakeItem

pub struct TakeItem<T> { /* fields omitted */ }

NewService that implements, read one item from the stream.

Methods

impl<T> TakeItem<T>

pub fn new() -> Self

Create new TakeRequest instance.

Trait Implementations

impl<T: Stream> NewService for TakeItem<T>

type Request = T

Requests handled by the service

type Response = (Option<T::Item>, T)

Responses given by the service

type Error = T::Error

Errors produced by the service

type InitError = ()

Errors produced while building a service.

type Service = TakeItemService<T>

The Service value created by this factory

type Future = FutureResult<Self::Service, Self::InitError>

The future of the Service instance.

fn new_service(&self) -> Self::Future

Create and return a new service value asynchronously.