pub fn create(actor: A) -> impl Stream<Item = Result<Bytes, Error>> {
        let mb = Mailbox::default();
        let ctx = HttpContext {
            inner: ContextParts::new(mb.sender_producer()),
            stream: VecDeque::new(),
        };
        HttpContextFut::new(ctx, actor, mb)
    }
/// Create a new HTTP Context from a request and an actor
Create a new HTTP Context from a request and an actor
Create a new HTTP Context from a request and an actor
pub fn create(actor: A) -> impl Stream<Item = Result<Bytes, Error>> {
        let mb = Mailbox::default();
        let ctx = HttpContext {
            inner: ContextParts::new(mb.sender_producer()),
            stream: VecDeque::new(),
        };
        HttpContextFut::new(ctx, actor, mb)
    }
pub fn create ( actor : A ) -> impl Stream < Item = Result < Bytes , Error > > { let mb = Mailbox :: default ( ) ; let ctx = HttpContext { inner : ContextParts :: new ( mb . sender_producer ( ) ) , stream : VecDeque :: new ( ) , } ; HttpContextFut :: new ( ctx , actor , mb ) }
Create a new HTTP Context from a request and an actor
Create a new HTTP Context from a request and an actor
actor
A
actor
A