tests(coordinator): Improve unit test coverage

Signed-off-by: Flc゛ <[email protected]>

coordinator/manager.go

@@ -4,7 +4,7 @@ import "sync"
 
 type Manager struct {
 	coordinators map[string]*Coordinator
-	mu           sync.RWMutex
+	mu           sync.Mutex
 }
 
 func NewManager() *Manager {

coordinator/manager_test.go

@@ -39,4 +39,30 @@ func TestManager(t *testing.T) {
 
 	wg.Wait()
 	assert.Equal(t, 2, len(ch))
+
+	// Clear all coordinators
+	Clear()
+
+	c3 := Until("foo")
+	assert.NotSame(t, c1, c3)
+
+	// Close foo coordinators
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+
+		if <-c3.Done(); true {
+			ch <- struct{}{}
+			return
+		}
+	}()
+	assert.Equal(t, 2, len(ch))
+	Close("foo")
+	wg.Wait()
+	assert.Equal(t, 3, len(ch))
+
+	// Close non-exist coordinator
+	assert.NotPanics(t, func() {
+		Close("bar")
+	})
 }