pub fn remote_stream_initiated(&mut self, id: StreamId) -> Result<()> {
        if let Some(max_id) = self.go_away {
            if id.index() > max_id.index() {
                warn!(id=%id, "rejecting");
                return Err(Error::Aborted);
            }
        }
        debug!(id=%id, "accepting");
        self.requests_in_flight.insert(id);
        if id.index() > self.max_id_in_flight.index() {
            self.max_id_in_flight = id
        };
        Ok(())
    }
// The remote peer initiated a stream: a request from client or a push from server
The remote peer initiated a stream: a request from client or a push from server
The remote peer initiated a stream : a request from client or a push from server
pub fn remote_stream_initiated(&mut self, id: StreamId) -> Result<()> {
        if let Some(max_id) = self.go_away {
            if id.index() > max_id.index() {
                warn!(id=%id, "rejecting");
                return Err(Error::Aborted);
            }
        }
        debug!(id=%id, "accepting");
        self.requests_in_flight.insert(id);
        if id.index() > self.max_id_in_flight.index() {
            self.max_id_in_flight = id
        };
        Ok(())
    }
pub fn remote_stream_initiated ( & mut self , id : StreamId ) -> Result < ( ) > { if let Some ( max_id ) = self . go_away { if id . index ( ) > max_id . index ( ) { warn ! ( id id " " ) ; return Err ( Error :: Aborted ) ; } } debug ! ( id id " " ) ; self . requests_in_flight . insert ( id ) ; if id . index ( ) > self . max_id_in_flight . index ( ) { self . max_id_in_flight = id } ; Ok ( ( ) ) }
The remote peer initiated a stream: a request from client or a push from server
The remote peer initiated a stream : a request from client or a push from server
&mut self
id
StreamId