tendermint/internal/libs/sync/closer_test.go

package sync_test

import (
	"testing"
	"time"

	"github.com/stretchr/testify/require"
	tmsync "github.com/tendermint/tendermint/internal/libs/sync"
)

func TestCloser(t *testing.T) {
	closer := tmsync.NewCloser()

	var timeout bool

	select {
	case <-closer.Done():
	case <-time.After(time.Second):
		timeout = true
	}

	for i := 0; i < 10; i++ {
		closer.Close()
	}

	require.True(t, timeout)
	<-closer.Done()
}