pub fn run<'s>(
        self,
        ctx: &ExtensionContext<'_>,
        stream: BoxStream<'s, Response>,
    ) -> BoxStream<'s, Response> {
        if let Some((first, next)) = self.chain.split_first() {
            first.subscribe(ctx, stream, NextSubscribe { chain: next })
        } else {
            stream
        }
    }
/// Call the [Extension::subscribe] function of next extension.
Call the [Extension::subscribe] function of next extension.
Call the [ Extension :: subscribe ] function of next extension .
pub fn run<'s>(
        self,
        ctx: &ExtensionContext<'_>,
        stream: BoxStream<'s, Response>,
    ) -> BoxStream<'s, Response> {
        if let Some((first, next)) = self.chain.split_first() {
            first.subscribe(ctx, stream, NextSubscribe { chain: next })
        } else {
            stream
        }
    }
pub fn run < ' s > ( self , ctx : & ExtensionContext < ' _ > , stream : BoxStream < ' s , Response > , ) -> BoxStream < ' s , Response > { if let Some ( ( first , next ) ) = self . chain . split_first ( ) { first . subscribe ( ctx , stream , NextSubscribe { chain : next } ) } else { stream } }
Call the [Extension::subscribe] function of next extension.
Call the [ Extension :: subscribe ] function of next extension .
self
ctx
&ExtensionContext<'_>
stream
BoxStream<'s, Response>
self
ctx
&ExtensionContext<'_>
stream
BoxStream<'s, Response>