DO NOT REVIEW

.github/workflows/test-and-upload-coverage.yml

@@ -31,9 +31,9 @@ jobs:
       fail-fast: false
       matrix:
         os: [ubuntu-latest]
-        client-type: [go, http, cli]
-        database-type: [badger-file, badger-memory]
-        mutation-type: [gql, collection-named, collection-save]
+        client-type: [go]
+        database-type: [badger-file]
+        mutation-type: [gql]
         lens-type: [wasm-time]
         detect-changes: [false]
         database-encryption: [false]
@@ -117,48 +117,5 @@ jobs:
 
       - name: Run integration tests
         if: ${{ !matrix.detect-changes }}
-        run: make test:coverage
+        run: go test ./events --run TestSimpleEachSubscribersRecievesEachItemGivenBufferedEventChan2
 
-      - name: Run change detector tests
-        if: ${{ matrix.detect-changes }}
-        run: make test:changes
-
-      - name: Upload coverage artifact
-        if: ${{ !matrix.detect-changes }}
-        uses: actions/upload-artifact@v3
-        with:
-          name: ${{ matrix.os }}_${{ matrix.client-type }}_${{ matrix.database-type }}_${{ matrix.mutation-type }}
-          path: coverage.txt
-          if-no-files-found: error
-          retention-days: 7
-
-  upload-coverage:
-    name: Upload test code coverage job
-
-    needs: run-tests
-
-    # Important to know:
-    # - We didn't use `if: always()` here, so this job doesn't run if we manually canceled.
-    # - `if: success()` is always implied unless `always()` or `failure()` is specified.
-    if: success() || failure()
-
-    runs-on: ubuntu-latest
-
-    steps:
-      - name: Checkout code into the directory
-        uses: actions/checkout@v3
-
-      - name: Download coverage reports
-        uses: actions/download-artifact@v3
-        with:
-          path: coverage_reports
-
-      - name: Upload coverage to Codecov
-        uses: codecov/codecov-action@v4
-        with:
-          token: ${{ secrets.CODECOV_TOKEN }}
-          name: defradb-codecov
-          flags: all-tests
-          os: 'linux'
-          fail_ci_if_error: true
-          verbose: true

events/simple_test.go

@@ -108,3 +108,27 @@ func TestSimpleSubscribersDontRecieveItemsAfterUnsubscribing(t *testing.T) {
 	// closing the channel will result in reads yielding the default value
 	assert.Equal(t, 0, <-ch)
 }
+func TestSimpleEachSubscribersRecievesEachItemGivenBufferedEventChan2(t *testing.T) {
+	c := NewSimpleChannel[Update](1000000, 5)
+	for i := 0; i < 100; i++ {
+		sub, err := c.Subscribe()
+		if err != nil {
+			panic(err)
+		}
+		defer c.Unsubscribe(sub)
+		go handleChannelMessages(sub)
+	}
+	for i := 0; i < 1000; i++ {
+		c.Publish(
+			Update{
+				DocID: "test",
+			},
+		)
+	}
+}
+func handleChannelMessages(sub Subscription[Update]) {
+	for msg := range sub {
+		_ = msg
+		time.Sleep(1 * time.Millisecond)
+	}
+}