Create memory allocation for bus instance

alexandria-oss · Apr 25, 2023 · c6dcfe7 · c6dcfe7
1 parent 2da78b0
commit c6dcfe7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/bus.go b/bus.go
@@ -9,9 +9,9 @@ type Bus struct {
 }
 
 // NewBus allocates a Bus instance. Specify options to customize Publisher's default configurations.
-func NewBus(w Writer, r Reader, options ...PublisherOption) Bus {
+func NewBus(w Writer, r Reader, options ...PublisherOption) *Bus {
 	reg := make(EventRegistry)
-	return Bus{
+	return &Bus{
 		EventRegistry:       reg,
 		Publisher:           NewPublisher(w, reg, options...),
 		SubscriberScheduler: NewSubscriberScheduler(r, reg),

diff --git a/bus_test.go b/bus_test.go
@@ -43,12 +43,12 @@ func TestBus(t *testing.T) {
 			t.Error(errStart)
 			return
 		}
-	}(&bus)
+	}(bus)
 	defer func(bus *streams.Bus) {
 		if errStop := bus.Shutdown(); errStop != nil {
 			t.Fatal(errStop)
 		}
-	}(&bus)
+	}(bus)
 	defer chanbuf.DefaultBus.Shutdown()
 	err := bus.Publish(context.TODO(), anyEvent{
 		ID: "123-foo",