Function TestOutOfOrderWithEOF

pkg/streamclient/stream_test.go:481–523

(t *testing.T)

}

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

	packet0 := wshrpc.CommandStreamData{
		Id:     "test-eof",
		Seq:    0,
		Data64: base64.StdEncoding.EncodeToString([]byte("first")),
	}
	packet11 := wshrpc.CommandStreamData{
		Id:     "test-eof",
		Seq:    11,
		Data64: base64.StdEncoding.EncodeToString([]byte("third")),
		Eof:    true,
	}
	packet5 := wshrpc.CommandStreamData{
		Id:     "test-eof",
		Seq:    5,
		Data64: base64.StdEncoding.EncodeToString([]byte("second")),
	}

	reader.RecvData(packet0)
	reader.RecvData(packet11) // OOO with EOF
	reader.RecvData(packet5)  // Fill the gap

	// Read all data
	buf := make([]byte, 20)
	n, err := reader.Read(buf)
	if err != nil {
		t.Fatalf("Read failed: %v", err)
	}
	
	expected := "firstsecondthird"
	if string(buf[:n]) != expected {
		t.Fatalf("Expected %q, got %q", expected, string(buf[:n]))
	}

	// Should get EOF now
	_, err = reader.Read(buf)
	if err != io.EOF {
		t.Fatalf("Expected EOF, got %v", err)
	}
}