Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ReadBytes (0.05 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(frame2.type).isEqualTo(Http2.TYPE_RST_STREAM)
        val frame3 = peer.takeFrame()
        assertThat(frame3.type).isEqualTo(Http2.TYPE_RST_STREAM)
        assertThat(connection.readBytes.acknowledged).isEqualTo(0L)
        assertThat(connection.readBytes.total).isEqualTo(2048L)
      }
    
      @Test fun receiveGoAwayHttp2() {
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
        peer.acceptFrame() // ACK
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  2. src/bufio/bufio_test.go

    }
    
    func TestReaderSimple(t *testing.T) {
    	data := "hello world"
    	b := NewReader(strings.NewReader(data))
    	if s := readBytes(b); s != "hello world" {
    		t.Errorf("simple hello world test failed: got %q", s)
    	}
    
    	b = NewReader(newRot13Reader(strings.NewReader(data)))
    	if s := readBytes(b); s != "uryyb jbeyq" {
    		t.Errorf("rot13 hello world test failed: got %q", s)
    	}
    }
    
    type readMaker struct {
    	name string
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_gen.go

    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *xlMetaBuf) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 []byte
    		zb0001, err = dc.ReadBytes([]byte((*z)))
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = xlMetaBuf(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
Back to top