util

func AssertClosed(t testing.TB, closed <-chan struct{}, name string)

func AssertMessage(t testing.TB, messages <-chan []byte, expected string)

func AssertNoAsyncError(t testing.TB, asyncErrors <-chan error)

func CloseClient(t testing.TB, client *arctic.Client)

func CloseClients(t testing.TB, clients []*arctic.Client)

func CloseGobServer[MessageType any](
	t testing.TB,
	server *arctic.GobServer[MessageType],
	listenDone <-chan error,
)

func CloseServer(t testing.TB, server *arctic.Server, listenDone <-chan error)

func IsExpectedAsyncCloseError(err error) (expected bool)

func NewUDPClient(
	t testing.TB,
	address string,
	asyncErrors chan<- error,
) (client *arctic.Client, messages chan []byte)

func StartGobServer[MessageType any](
	t testing.TB,
	server *arctic.GobServer[MessageType],
) (listenDone chan error)

func StartServer(t testing.TB, server *arctic.Server) (listenDone chan error)

func WaitBenchmarkResponse(t testing.TB, responses <-chan []byte)

func WaitForAddress(t testing.TB, provider AddressProvider) (address string)

func WaitForListenExit(t testing.TB, listenDone <-chan error)