Mirrors
/
prologic-msgbus
mirror of https://git.mills.io/prologic/msgbus.git
6
0
Fork 0
Code Issues Projects Releases Wiki Activity

use New instead of NewMessageBus for main message bus constructor (#5) 

* use New instead of NewMessageBus for main message bus constructor

* update readme: New as message bus constructor
This commit is contained in:
Alexander Emelin 2018-05-08 11:50:56 +03:00 committed by James Mills
parent 8da5d41e65
commit 22efa3afc8
3 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -56,7 +56,7 @@ import (
)
func main() {
m := msgbus.NewMessageBus()
m := msgbus.New()
m.Put("foo", m.NewMessage([]byte("Hello World!")))
msg, ok := m.Get("foo")

4
msgbus.go
View File

@ -142,8 +142,8 @@ type MessageBus struct {
listeners map[*Topic]*Listeners
}
// NewMessageBus ...
func NewMessageBus(options *Options) *MessageBus {
// New ...
func New(options *Options) *MessageBus {
var (
ttl time.Duration
withMetrics bool

16
msgbus_test.go
View File

@ -7,12 +7,12 @@ import (
)
func TestMessageBusLen(t *testing.T) {
mb := NewMessageBus(nil)
mb := New(nil)
assert.Equal(t, mb.Len(), 0)
}
func TestMessage(t *testing.T) {
mb := NewMessageBus(nil)
mb := New(nil)
assert.Equal(t, mb.Len(), 0)
topic := mb.NewTopic("foo")
@ -25,7 +25,7 @@ func TestMessage(t *testing.T) {
}
func TestMessageGetEmpty(t *testing.T) {
mb := NewMessageBus(nil)
mb := New(nil)
assert.Equal(t, mb.Len(), 0)
topic := mb.NewTopic("foo")
@ -35,7 +35,7 @@ func TestMessageGetEmpty(t *testing.T) {
}
func TestMessageBusPutGet(t *testing.T) {
mb := NewMessageBus(nil)
mb := New(nil)
topic := mb.NewTopic("foo")
expected := Message{Topic: topic, Payload: []byte("foo")}
mb.Put(expected)
@ -46,7 +46,7 @@ func TestMessageBusPutGet(t *testing.T) {
}
func BenchmarkMessageBusPut(b *testing.B) {
mb := NewMessageBus(nil)
mb := New(nil)
topic := mb.NewTopic("foo")
msg := Message{Topic: topic, Payload: []byte("foo")}
b.ResetTimer()
@ -56,7 +56,7 @@ func BenchmarkMessageBusPut(b *testing.B) {
}
func BenchmarkMessageBusGet(b *testing.B) {
mb := NewMessageBus(nil)
mb := New(nil)
topic := mb.NewTopic("foo")
msg := Message{Topic: topic, Payload: []byte("foo")}
for i := 0; i < b.N; i++ {
@ -69,7 +69,7 @@ func BenchmarkMessageBusGet(b *testing.B) {
}
func BenchmarkMessageBusGetEmpty(b *testing.B) {
mb := NewMessageBus(nil)
mb := New(nil)
topic := mb.NewTopic("foo")
b.ResetTimer()
for i := 0; i < b.N; i++ {
@ -78,7 +78,7 @@ func BenchmarkMessageBusGetEmpty(b *testing.B) {
}
func BenchmarkMessageBusPutGet(b *testing.B) {
mb := NewMessageBus(nil)
mb := New(nil)
topic := mb.NewTopic("foo")
msg := Message{Topic: topic, Payload: []byte("foo")}
b.ResetTimer()