fn close_qpack_stream() {
        let mut s = Session::default().unwrap();
        s.handshake().unwrap();

        let mut qpack_stream_closed = false;

        let stream_id = s.client.local_qpack_streams.encoder_stream_id.unwrap();
        let d = [0; 1];

        s.pipe.client.stream_send(stream_id, &d, false).unwrap();
        s.pipe.client.stream_send(stream_id, &d, true).unwrap();

        s.advance().ok();

        loop {
            match s.server.poll(&mut s.pipe.server) {
                Ok(_) => (),

                Err(Error::Done) => {
                    break;
                },

                Err(Error::ClosedCriticalStream) => {
                    qpack_stream_closed = true;
                    break;
                },

                Err(_) => (),
            }
        }

        assert!(qpack_stream_closed);
    }
/// Client closes QPACK stream, which is forbidden.
Client closes QPACK stream, which is forbidden.
Client closes QPACK stream which is forbidden .
fn close_qpack_stream() {
        let mut s = Session::default().unwrap();
        s.handshake().unwrap();
        let mut qpack_stream_closed = false;
        let stream_id = s.client.local_qpack_streams.encoder_stream_id.unwrap();
        let d = [0; 1];
        s.pipe.client.stream_send(stream_id, &d, false).unwrap();
        s.pipe.client.stream_send(stream_id, &d, true).unwrap();
        s.advance().ok();
        loop {
            match s.server.poll(&mut s.pipe.server) {
                Ok(_) => (),
                Err(Error::Done) => {
                    break;
                },
                Err(Error::ClosedCriticalStream) => {
                    qpack_stream_closed = true;
                    break;
                },
                Err(_) => (),
            }
        }
        assert!(qpack_stream_closed);
    }
fn close_qpack_stream ( ) { let mut s = Session :: default ( ) . unwrap ( ) ; s . handshake ( ) . unwrap ( ) ; let mut qpack_stream_closed = false ; let stream_id = s . client . local_qpack_streams . encoder_stream_id . unwrap ( ) ; let d = [ 0 ; 1 ] ; s . pipe . client . stream_send ( stream_id , & d , false ) . unwrap ( ) ; s . pipe . client . stream_send ( stream_id , & d , true ) . unwrap ( ) ; s . advance ( ) . ok ( ) ; loop { match s . server . poll ( & mut s . pipe . server ) { Ok ( _ ) => ( ) , Err ( Error :: Done ) => { break ; } , Err ( Error :: ClosedCriticalStream ) => { qpack_stream_closed = true ; break ; } , Err ( _ ) => ( ) , } } assert ! ( qpack_stream_closed ) ; }
Client closes QPACK stream, which is forbidden.
Client closes QPACK stream which is forbidden .