- Added: doc example test

- Updated: Improved splited up bus benchmark test
- Bugfix: Wrong method call in README example

bus/README.md

@@ -30,6 +30,6 @@ func main() {
         return nil
     })
 
-    b.Dispatch(new(msg))
+    b.Publish(new(msg))
 }
 ```

bus/bus_test.go

@@ -101,50 +101,46 @@ func TestAddListenerBadFunc(t *testing.T) {
 	})
 }
 
-func BenchmarkRun(b *testing.B) {
+func BenchmarkHandlerRun(b *testing.B) {
 	for n := 0; n < b.N; n++ {
-		b := bus.New()
+		bus := bus.New()
 
-		b.AddEventListener(func(m *msg) error {
+		bus.AddHandler(func(m *msg) error {
 			return nil
 		})
 
-		b.AddEventListener(func(m *msg) error {
-			return nil
-		})
-
-		b.AddEventListener(func(m *msg) error {
-			return nil
-		})
-
-		b.AddEventListener(func(m *msg) error {
-			return nil
-		})
+		if err := bus.Dispatch(new(msg)); err != nil {
+			b.Fatal(err)
+		}
+	}
+}
 
-		b.AddEventListener(func(m *msg) error {
-			return nil
-		})
+func BenchmarkListenerRun(b *testing.B) {
+	for n := 0; n < b.N; n++ {
+		bus := bus.New()
 
-		b.AddHandler(func(m *msg) error {
+		bus.AddEventListener(func(m *msg) error {
 			return nil
 		})
 
-		b.AddHandler(func(m *msg) error {
+		bus.AddEventListener(func(m *msg) error {
 			return nil
 		})
 
-		b.AddHandler(func(m *msg) error {
+		bus.AddEventListener(func(m *msg) error {
 			return nil
 		})
 
-		b.AddHandler(func(m *msg) error {
+		bus.AddEventListener(func(m *msg) error {
 			return nil
 		})
 
-		b.AddHandler(func(m *msg) error {
+		bus.AddEventListener(func(m *msg) error {
 			return nil
 		})
 
-		b.Dispatch(new(msg))
+		if err := bus.Publish(new(msg)); err != nil {
+			b.Fatal(err)
+		}
 	}
 }

bus/doc_test.go

@@ -0,0 +1,28 @@
+package bus_test
+
+import (
+	"fmt"
+	"github.com/donutloop/toolkit/bus"
+)
+
+// Creates a bus and adds a listener to a message afterward it publishes a new message
+func ExampleBus() {
+
+	type msg struct {
+		Id   int64
+		body string
+	}
+
+	b := bus.New()
+
+	b.AddEventListener(func(m *msg) error {
+		fmt.Println("db insert listener")
+		return nil
+	})
+
+	if err := b.Publish(new(msg)); err != nil {
+		fmt.Println(fmt.Sprintf("bus: %v", err))
+	}
+
+	// Output: db insert listener
+}