edge/pkg/bus/memory/bus_test.go

package memory

import (
	"testing"

	busTesting "forge.cadoles.com/arcad/edge/pkg/bus/testing"
	"gitlab.com/wpetit/goweb/logger"
	"go.uber.org/goleak"
)

func TestMain(m *testing.M) {
	goleak.VerifyTestMain(m)
}

func TestMemoryBus(t *testing.T) {
	if testing.Short() {
		t.Skip("Test disabled when -short flag is set")
	}

	if testing.Verbose() {
		logger.SetLevel(logger.LevelDebug)
	}

	t.Parallel()

	t.Run("PublishSubscribe", func(t *testing.T) {
		t.Parallel()

		b := NewBus()
		busTesting.TestPublishSubscribe(t, b)
	})

	t.Run("RequestReply", func(t *testing.T) {
		t.Parallel()

		b := NewBus()
		busTesting.TestRequestReply(t, b)
	})

	t.Run("CanceledRequestReply", func(t *testing.T) {
		t.Parallel()

		b := NewBus()
		busTesting.TestCanceledRequest(t, b)
	})
}