test

May 19, 2025

Changes in this version

+ func TestNilPayloadMessagePublishingAndReceiving(fixture PubSubFixture) func(t *testing.T)

May 17, 2025

Changes in this version

+ func NewPublishingBenchmark(p message.Publisher) func(*testing.B)

+ func NewSubscriptionBenchmark(s message.Subscriber) func(*testing.B)

+ func OfficialImplementationAcceptance(fixture PubSubFixture) func(t *testing.T)

+ func TestBasicSendRecieve(setup PubSubFixture) func(t *testing.T)

+ func TestHungOperations(setup PubSubFixture) func(t *testing.T)

+ func TestOnePublisherThreeSubscribers(setup PubSubFixture, messageCount int) func(t *testing.T)

+ type PubSubFixture func(t *testing.T, consumerGroup string) (message.Publisher, message.Subscriber)

+ func (f PubSubFixture) WithConsumerGroup(consumerGroup string) func(t *testing.T) (message.Publisher, message.Subscriber)