add test

api/client/event/event_stream_test.go

@@ -79,3 +79,24 @@ func TestEventStream(t *testing.T) {
 		}
 	}
 }
+
+func TestEventStreamRequestError(t *testing.T) {
+	topics := []string{"head"}
+	eventsChannel := make(chan *Event, 1)
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	// use valid url that will result in failed request with nil body
+	stream, err := NewEventStream(ctx, http.DefaultClient, "http://badhost:1234", topics)
+	require.NoError(t, err)
+
+	// error will happen when request is made, should be received over events channel
+	go stream.Subscribe(eventsChannel)
+
+	select {
+	case event := <-eventsChannel:
+		if event.EventType != EventConnectionError {
+			t.Errorf("Expected event type %q, got %q", EventConnectionError, event.EventType)
+		}
+	}
+}