diff --git a/network/transport/grpc/connection_test.go b/network/transport/grpc/connection_test.go index 5b4a6e2cec..101fda5b0f 100644 --- a/network/transport/grpc/connection_test.go +++ b/network/transport/grpc/connection_test.go @@ -20,11 +20,8 @@ package grpc import ( "context" - "github.com/nuts-foundation/nuts-node/test" "github.com/stretchr/testify/require" - "google.golang.org/grpc/codes" "sync" - "sync/atomic" "testing" "time" @@ -104,30 +101,6 @@ func Test_conn_registerStream(t *testing.T) { }) } -func Test_conn_startSending(t *testing.T) { - t.Run("disconnect does not panic", func(t *testing.T) { - connection := createConnection(context.Background(), transport.Peer{}).(*conn) - stream := newServerStream("foo", "", nil) - - defer stream.cancelFunc() - - p := &TestProtocol{} - _ = connection.registerStream(p, stream) - - assert.Equal(t, int32(2), connection.activeGoroutines) // startSending and startReceiving - - stream.cancelFunc() - connection.disconnect() - - test.WaitFor(t, func() (bool, error) { - return atomic.LoadInt32(&connection.activeGoroutines) == 0, nil - }, 5*time.Second, "waiting for all goroutines to exit") - - // Last received message is dropped and no status is set. Default value is OK. - assert.Equal(t, codes.OK, connection.status.Load().Code()) - }) -} - func TestConn_Send(t *testing.T) { t.Run("buffer overflow softlimit", func(t *testing.T) { connection := createConnection(context.Background(), transport.Peer{}).(*conn)