pub fn go_away(&mut self, allow_streams: u64) {
        let dir = match self.side {
            Side::Server => Dir::Bi,
            Side::Client => Dir::Uni,
        };
        let max_id = StreamId::new(
            !self.side,
            dir,
            self.max_id_in_flight.index() + allow_streams,
        );
        debug!(last_stream=%max_id, "shutting down");
        self.go_away = Some(max_id);
        HttpFrame::Goaway(self.max_id_in_flight.0)
            .encode(&mut self.pending_streams[PendingStreamType::Control as usize]);
    }
// A graceful shutdown initiated locally, let `allow_streams` potentially in-flight
// incoming streams be processed.
A graceful shutdown initiated locally, let `allow_streams` potentially in-flight
incoming streams be processed.
A graceful shutdown initiated locally let ` allow_streams ` potentially in - flight incoming streams be processed .
pub fn go_away(&mut self, allow_streams: u64) {
        let dir = match self.side {
            Side::Server => Dir::Bi,
            Side::Client => Dir::Uni,
        };
        let max_id = StreamId::new(
            !self.side,
            dir,
            self.max_id_in_flight.index() + allow_streams,
        );
        debug!(last_stream=%max_id, "shutting down");
        self.go_away = Some(max_id);
        HttpFrame::Goaway(self.max_id_in_flight.0)
            .encode(&mut self.pending_streams[PendingStreamType::Control as usize]);
    }
pub fn go_away ( & mut self , allow_streams : u64 ) { let dir = match self . side { Side :: Server => Dir :: Bi , Side :: Client => Dir :: Uni , } ; let max_id = StreamId :: new ( ! self . side , dir , self . max_id_in_flight . index ( ) + allow_streams , ) ; debug ! ( last_stream max_id " " ) ; self . go_away = Some ( max_id ) ; HttpFrame :: Goaway ( self . max_id_in_flight . 0 ) . encode ( & mut self . pending_streams [ PendingStreamType :: Control as usize ] ) ; }
A graceful shutdown initiated locally, let `allow_streams` potentially in-flight
incoming streams be processed.
A graceful shutdown initiated locally let ` allow_streams ` potentially in - flight incoming streams be processed .
&mut self
allow_streams
u64