Struct FakeBus

core/services/testutil/fakebus.go:23–34

FakeBus is an in-memory messaging.MessagingClient that delivers each published message synchronously to every registered subscriber whose subject filter matches, including NATS-style wildcard subjects (`*` matches exactly one token). Synchronous delivery keeps specs deterministic: the moment Publis

// delivery semantics. It deliberately depends only on the standard library and
// the messaging package — no test framework — so it is importable anywhere.
type FakeBus struct {
	mu   sync.Mutex
	subs []fakeBusSub
	// publishCounts records how many messages were published per subject, so a
	// spec can assert the echo-loop guard (an applied delta must not re-publish).
	publishCounts map[string]int

	// reconnectCbs back the optional OnReconnect/TriggerReconnect pair, letting a
	// spec exercise the component's reconnect re-hydrate path without a real
	// NATS server.
	reconnectCbs []func()
}

type fakeBusSub struct {
	subject string