Function TestOutOfOrderWithGaps

pkg/streamclient/stream_test.go:381–479

(t *testing.T)

}

func TestOutOfOrderWithGaps(t *testing.T) {
	transport := newFakeTransport()
	reader := NewReader("test-gaps", 1024, transport)

	packet0 := wshrpc.CommandStreamData{
		Id:     "test-gaps",
		Seq:    0,
		Data64: base64.StdEncoding.EncodeToString([]byte("aaaaa")),
	}
	packet20 := wshrpc.CommandStreamData{
		Id:     "test-gaps",
		Seq:    20,
		Data64: base64.StdEncoding.EncodeToString([]byte("eeeee")),
	}
	packet40 := wshrpc.CommandStreamData{
		Id:     "test-gaps",
		Seq:    40,
		Data64: base64.StdEncoding.EncodeToString([]byte("iiiii")),
	}
	packet5 := wshrpc.CommandStreamData{
		Id:     "test-gaps",
		Seq:    5,
		Data64: base64.StdEncoding.EncodeToString([]byte("bbbbb")),
	}

	reader.RecvData(packet0)
	reader.RecvData(packet40) // Way ahead - should be buffered
	reader.RecvData(packet20) // Still ahead - should be buffered
	
	// Read first packet
	buf := make([]byte, 10)
	n, err := reader.Read(buf)
	if err != nil {
		t.Fatalf("Read failed: %v", err)
	}
	if n != 5 || string(buf[:n]) != "aaaaa" {
		t.Fatalf("Expected 'aaaaa', got %q", string(buf[:n]))
	}

	// Send packet to partially fill gap
	reader.RecvData(packet5)

	// Should be able to read it now
	n, err = reader.Read(buf)
	if err != nil {
		t.Fatalf("Second read failed: %v", err)
	}
	if n != 5 || string(buf[:n]) != "bbbbb" {
		t.Fatalf("Expected 'bbbbb', got %q", string(buf[:n]))
	}

	packet10 := wshrpc.CommandStreamData{
		Id:     "test-gaps",
		Seq:    10,
		Data64: base64.StdEncoding.EncodeToString([]byte("ccccc")),
	}
	packet15 := wshrpc.CommandStreamData{
		Id:     "test-gaps",