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

        let mut d = [42; 128];
        let mut b = octets::OctetsMut::with_slice(&mut d);

        let frame_type = b.put_varint(148_764_065_110_560_899).unwrap();
        s.pipe.client.stream_send(0, frame_type, false).unwrap();

        let frame_len = b.put_varint(1 << 24).unwrap();
        s.pipe.client.stream_send(0, frame_len, false).unwrap();

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

        s.advance().ok();

        assert_eq!(s.server.poll(&mut s.pipe.server), Err(Error::ExcessiveLoad));

        // Try to call poll() again after an error occurred.
        assert_eq!(s.server.poll(&mut s.pipe.server), Err(Error::Done));
    }
/// Tests that calling poll() after an error occured does nothing.
Tests that calling poll() after an error occured does nothing.
Tests that calling poll () after an error occured does nothing .
fn poll_after_error() {
        let mut s = Session::default().unwrap();
        s.handshake().unwrap();
        let mut d = [42; 128];
        let mut b = octets::OctetsMut::with_slice(&mut d);
        let frame_type = b.put_varint(148_764_065_110_560_899).unwrap();
        s.pipe.client.stream_send(0, frame_type, false).unwrap();
        let frame_len = b.put_varint(1 << 24).unwrap();
        s.pipe.client.stream_send(0, frame_len, false).unwrap();
        s.pipe.client.stream_send(0, &d, false).unwrap();
        s.advance().ok();
        assert_eq!(s.server.poll(&mut s.pipe.server), Err(Error::ExcessiveLoad));
        // Try to call poll() again after an error occurred.
        assert_eq!(s.server.poll(&mut s.pipe.server), Err(Error::Done));
    }
fn poll_after_error ( ) { let mut s = Session :: default ( ) . unwrap ( ) ; s . handshake ( ) . unwrap ( ) ; let mut d = [ 42 ; 128 ] ; let mut b = octets :: OctetsMut :: with_slice ( & mut d ) ; let frame_type = b . put_varint ( 148_764_065_110_560_899 ) . unwrap ( ) ; s . pipe . client . stream_send ( 0 , frame_type , false ) . unwrap ( ) ; let frame_len = b . put_varint ( 1 << 24 ) . unwrap ( ) ; s . pipe . client . stream_send ( 0 , frame_len , false ) . unwrap ( ) ; s . pipe . client . stream_send ( 0 , & d , false ) . unwrap ( ) ; s . advance ( ) . ok ( ) ; assert_eq ! ( s server poll ( mut s pipe server ) Err ( Error ExcessiveLoad ) ) ; // Try to call poll() again after an error occurred. assert_eq ! ( s server poll ( mut s pipe server ) Err ( Error Done ) ) ; }
Tests that calling poll() after an error occured does nothing.
Tests that calling poll () after an error occured does nothing .