pub fn new(f: F) -> Self {
        Self {
            f,
            _w: std::marker::PhantomData,
        }
    }
/// Create a new stream protocol parser with a response closure
///
/// The provided function will be called for every incoming
/// response to the stream protocol.  You can use it, and the
/// mutable access to your worker state to map response messages
/// to the worker state.
Create a new stream protocol parser with a response closure
The provided function will be called for every incoming
response to the stream protocol.  You can use it, and the
mutable access to your worker state to map response messages
to the worker state.
Create a new stream protocol parser with a response closure The provided function will be called for every incoming response to the stream protocol . You can use it and the mutable access to your worker state to map response messages to the worker state .
pub fn new(f: F) -> Self {
        Self {
            f,
            _w: std::marker::PhantomData,
        }
    }
pub fn new ( f : F ) -> Self { Self { f , _w : std :: marker :: PhantomData , } }
Create a new stream protocol parser with a response closure
The provided function will be called for every incoming
response to the stream protocol.
Create a new stream protocol parser with a response closure The provided function will be called for every incoming response to the stream protocol .
f
F
f
F