A BUG on internal/store/inmem.go

[wanggeng01041454]

In Push Function, I think you forget :

m.events = events

And more, if we can determain that " if the 'getter' do not consume the message, the 'pusher' can not push new message", we can drop all of this code in Push function

// dorp it
	events := make([]*bridge.Event, 0, len(m.events)+1)
	for _, e := range m.events {
		if e.Deadline-tm > 0 { // cleanup outdated
			events = append(events, e)
		}
	}

And more and more, You always alloc new array in Push, and drop it in ExecuteAll. Can you implement a ring buffer to improve the profermance ?