test

livekit · Mar 26, 2024 · 025fae0 · 025fae0
1 parent 4810b11
commit 025fae0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/internal/test/my_service/my_service_test.go b/internal/test/my_service/my_service_test.go
@@ -127,7 +127,7 @@ func testGeneratedService(t *testing.T, bus func() psrpc.MessageBus) {
 	require.NoError(t, stream.Close(nil))
 
 	// let the service goroutine run
-	time.Sleep(time.Millisecond * 100)
+	time.Sleep(time.Second)
 
 	sA.Lock()
 	sB.Lock()
@@ -144,7 +144,7 @@ func testGeneratedService(t *testing.T, bus func() psrpc.MessageBus) {
 	require.NoError(t, sA.server.RegisterGetRegionStatsTopic("regionB"))
 	sA.server.DeregisterGetRegionStatsTopic("regionB")
 	require.NoError(t, sB.server.RegisterGetRegionStatsTopic("regionB"))
-	time.Sleep(time.Millisecond * 100)
+	time.Sleep(time.Second)
 
 	respChan, err = cB.GetRegionStats(ctx, "regionB", req)
 	require.NoError(t, err)
@@ -169,7 +169,7 @@ func testGeneratedService(t *testing.T, bus func() psrpc.MessageBus) {
 	require.NoError(t, err)
 	subB, err := cB.SubscribeProcessUpdate(ctx)
 	require.NoError(t, err)
-	time.Sleep(time.Millisecond * 100)
+	time.Sleep(time.Second)
 
 	require.NoError(t, sA.server.PublishProcessUpdate(ctx, update))
 	requireOne(t, subA, subB)
@@ -184,7 +184,7 @@ func testGeneratedService(t *testing.T, bus func() psrpc.MessageBus) {
 	require.NoError(t, err)
 	subB, err = cB.SubscribeUpdateRegionState(ctx, "regionA")
 	require.NoError(t, err)
-	time.Sleep(time.Millisecond * 100)
+	time.Sleep(time.Second)
 
 	require.NoError(t, sB.server.PublishUpdateRegionState(ctx, "regionA", update))
 	requireTwo(t, subA, subB)

diff --git a/internal/test/psrpc_test.go b/internal/test/psrpc_test.go
@@ -122,7 +122,7 @@ func testRPC(t *testing.T, bus func() psrpc.MessageBus) {
 	require.NoError(t, err)
 	err = server.RegisterHandler[*internal.Request, *internal.Response](serverB, rpc, nil, addOne, nil)
 	require.NoError(t, err)
-	time.Sleep(time.Millisecond * 100)
+	time.Sleep(time.Second)
 
 	ctx := context.Background()
 	requestID := rand.NewRequestID()
@@ -145,7 +145,7 @@ func testRPC(t *testing.T, bus func() psrpc.MessageBus) {
 	require.NoError(t, err)
 	err = server.RegisterHandler[*internal.Request, *internal.Response](serverC, multiRpc, nil, returnError, nil)
 	require.NoError(t, err)
-	time.Sleep(time.Millisecond * 100)
+	time.Sleep(time.Second)
 
 	requestID = rand.NewRequestID()
 	resChan, err := client.RequestMulti[*internal.Response](