Function TestError

pkg/streamclient/stream_test.go:164–193

(t *testing.T)

}

func TestError(t *testing.T) {
	transport := newFakeTransport()

	reader := NewReader("1", 1024, transport)
	writer := NewWriter("1", 1024, transport)

	go func() {
		for dataPk := range transport.dataChan {
			reader.RecvData(dataPk)
		}
	}()

	go func() {
		for ackPk := range transport.ackChan {
			writer.RecvAck(ackPk)
		}
	}()

	testErr := io.ErrUnexpectedEOF
	writer.CloseWithError(testErr)

	buf := make([]byte, 1024)
	_, err := reader.Read(buf)
	if err == nil {
		t.Fatal("Expected error from read")
	}
	if err.Error() != "stream error: unexpected EOF" {
		t.Fatalf("Expected stream error, got: %v", err)
	}
}

func TestCancel(t *testing.T) {
	transport := newFakeTransport()