From a2903f09cc5ec165d452c1d128ca7d32e8dd7490 Mon Sep 17 00:00:00 2001 From: Rowan Smith Date: Sun, 21 Jun 2026 23:44:18 +0000 Subject: [PATCH] buffer the logSource channel --- logger_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/logger_test.go b/logger_test.go index 0cae624..d978de9 100644 --- a/logger_test.go +++ b/logger_test.go @@ -1274,8 +1274,8 @@ func newFakeAgentAPI(t *testing.T) *fakeAgentAPI { mux := drpcmux.New() fakeAPI := &fakeAgentAPI{ disconnect: make(chan struct{}), - logs: make(chan []*proto.Log), - logSource: make(chan agentsdk.PostLogSourceRequest), + logs: make(chan []*proto.Log, 32), + logSource: make(chan agentsdk.PostLogSourceRequest, 32), } err := proto.DRPCRegisterAgent(mux, fakeAPI) require.NoError(t, err) @@ -1340,8 +1340,8 @@ func newFakeAgentAPI(t *testing.T) *fakeAgentAPI { func newFailingAgentAPI(t *testing.T) *fakeAgentAPI { fakeAPI := &fakeAgentAPI{ disconnect: make(chan struct{}), - logs: make(chan []*proto.Log), - logSource: make(chan agentsdk.PostLogSourceRequest), + logs: make(chan []*proto.Log, 32), + logSource: make(chan agentsdk.PostLogSourceRequest, 32), } // Create a server that always returns 401 Unauthorized errors