Function waitForConnectedClients

api/stream/stream_test.go:612–620

(api *API, count int)

}

func waitForConnectedClients(api *API, count int) {
	for i := 0; i < 10; i++ {
		if countClients(api) == count {
			// ok
			return
		}
		time.Sleep(10 * time.Millisecond)
	}
}