syncbus/example_test.go

package syncbus_test

import (
	"fmt"
	"sync"
	"time"

	"code.squareroundforest.org/arpio/syncbus"
)

type Server struct {
	resource int
	mx       sync.Mutex
	testBus  *syncbus.SyncBus
}

func (s *Server) AsyncInit() {
	go func() {
		s.mx.Lock()
		defer s.mx.Unlock()
		s.resource = 42
		s.testBus.Signal("initialized")
	}()
}

func (s *Server) Resource() int {
	s.mx.Lock()
	defer s.mx.Unlock()
	return s.resource
}

func Example() {
	bus := syncbus.New(120 * time.Millisecond)

	s := &Server{}
	s.testBus = bus
	s.AsyncInit()

	if err := bus.Wait("initialized"); err != nil {
		fmt.Println("failed:", err)
	}

	fmt.Println(s.Resource())
	// Output:
	// 42
}