Add Codecov and race detector (#15)

.github/workflows/check.yaml

@@ -28,4 +28,13 @@ jobs:
             ${{ runner.os }}-go-
 
       - name: Run tests
-        run: go test -v ./...
+        run: go test -race ./...
+
+      - name: Run coverage
+        run: go test -coverprofile=coverage.out -covermode=atomic ./...
+
+      - name: Upload coverage reports to Codecov
+        uses: codecov/[email protected]
+        with:
+          token: ${{ secrets.CODECOV_TOKEN }}
+          slug: destel/rill

internal/core/delay_test.go

@@ -31,8 +31,8 @@ func TestDelay(t *testing.T) {
 	}
 
 	t.Run("correctness", func(t *testing.T) {
-		const delay = 2 * time.Second
-		const eps = 100 * time.Millisecond
+		const delay = 5 * time.Second
+		const eps = 1000 * time.Millisecond // Race detector slows down the execution. Need to use larger epsilon
 
 		in := make(chan Item)
 		out := Delay(in, delay)
@@ -49,13 +49,16 @@ func TestDelay(t *testing.T) {
 			i++
 			th.ExpectValue(t, item.Value, i)
 			th.ExpectValueInDelta(t, time.Since(item.SentAt), delay, eps)
+			if t.Failed() {
+				t.FailNow()
+			}
 		}
 		th.ExpectValue(t, i, 100000-1)
 	})
 
 	t.Run("slow producer", func(t *testing.T) {
-		const delay = 2 * time.Second
-		const eps = 200 * time.Millisecond
+		const delay = 5 * time.Second
+		const eps = 1000 * time.Millisecond
 
 		in := make(chan Item)
 		out := Delay(in, delay)
@@ -84,7 +87,7 @@ func TestDelay(t *testing.T) {
 	})
 
 	t.Run("slow consumer", func(t *testing.T) {
-		const delay = 2 * time.Second
+		const delay = 5 * time.Second
 
 		in := make(chan Item)
 		out := Delay(in, delay)

internal/core/loops_test.go

@@ -105,7 +105,6 @@ func TestBreakable(t *testing.T) {
 		for x := range in1 {
 			if x == 100 {
 				earlyExit()
-				time.Sleep(1 * time.Second) // give Break some time to react and drain
 			}
 
 			if x > maxSeen {
@@ -120,6 +119,7 @@ func TestBreakable(t *testing.T) {
 
 		}
 
+		time.Sleep(1 * time.Second)
 		th.ExpectDrainedChan(t, in)
 	})