fn flow_control_limit_send() {
        let mut pipe = testing::Pipe::default().unwrap();
        assert_eq!(pipe.handshake(), Ok(()));

        assert_eq!(
            pipe.client.stream_send(0, b"aaaaaaaaaaaaaaa", false),
            Ok(15)
        );
        assert_eq!(pipe.advance(), Ok(()));
        assert_eq!(
            pipe.client.stream_send(4, b"aaaaaaaaaaaaaaa", false),
            Ok(15)
        );
        assert_eq!(pipe.advance(), Ok(()));
        assert_eq!(pipe.client.stream_send(8, b"a", false), Ok(0));
        assert_eq!(pipe.advance(), Ok(()));

        let mut r = pipe.server.readable();
        assert!(r.next().is_some());
        assert!(r.next().is_some());
        assert!(r.next().is_none());
    }
/// Tests that we don't exceed the per-connection flow control limit set by
/// the peer.
Tests that we don't exceed the per-connection flow control limit set by
the peer.
Tests that we don ' t exceed the per - connection flow control limit set by the peer .
fn flow_control_limit_send() {
        let mut pipe = testing::Pipe::default().unwrap();
        assert_eq!(pipe.handshake(), Ok(()));
        assert_eq!(
            pipe.client.stream_send(0, b"aaaaaaaaaaaaaaa", false),
            Ok(15)
        );
        assert_eq!(pipe.advance(), Ok(()));
        assert_eq!(
            pipe.client.stream_send(4, b"aaaaaaaaaaaaaaa", false),
            Ok(15)
        );
        assert_eq!(pipe.advance(), Ok(()));
        assert_eq!(pipe.client.stream_send(8, b"a", false), Ok(0));
        assert_eq!(pipe.advance(), Ok(()));
        let mut r = pipe.server.readable();
        assert!(r.next().is_some());
        assert!(r.next().is_some());
        assert!(r.next().is_none());
    }
fn flow_control_limit_send ( ) { let mut pipe = testing :: Pipe :: default ( ) . unwrap ( ) ; assert_eq ! ( pipe handshake ( ) Ok ( ( ) ) ) ; assert_eq ! ( pipe client stream_send ( 0 b" " false ) Ok ( 15 ) ) ; assert_eq ! ( pipe advance ( ) Ok ( ( ) ) ) ; assert_eq ! ( pipe client stream_send ( 4 b" " false ) Ok ( 15 ) ) ; assert_eq ! ( pipe advance ( ) Ok ( ( ) ) ) ; assert_eq ! ( pipe client stream_send ( 8 b" " false ) Ok ( 0 ) ) ; assert_eq ! ( pipe advance ( ) Ok ( ( ) ) ) ; let mut r = pipe . server . readable ( ) ; assert ! ( r next ( ) is_some ( ) ) ; assert ! ( r next ( ) is_some ( ) ) ; assert ! ( r next ( ) is_none ( ) ) ; }
Tests that we don't exceed the per-connection flow control limit set by
the peer.
Tests that we don ' t exceed the per - connection flow control limit set by the peer .