wartank/app_serv/vendor/fyne.io/fyne/v2/data/binding/queue.go

package binding

import (
	"sync"

	"fyne.io/fyne/v2/internal/async"
)

var (
	once  sync.Once
	queue *async.UnboundedFuncChan
)

func queueItem(f func()) {
	once.Do(func() {
		queue = async.NewUnboundedFuncChan()
		go func() {
			for f := range queue.Out() {
				f()
			}
		}()
	})
	queue.In() <- f
}

func waitForItems() {
	done := make(chan struct{})
	queue.In() <- func() { close(done) }
	<-done
}