assertTrue(response.isReceived());
        }

        @Test
        @DisplayName("Should handle concurrent error notifications")
        void testConcurrentError() throws InterruptedException {
            int threadCount = 10;
            CountDownLatch startLatch = new CountDownLatch(1);
            CountDownLatch endLatch = new CountDownLatch(threadCount);