Skip to content
Snippets Groups Projects
Commit a7828385 authored by Patrick's avatar Patrick
Browse files

optimize some code and fix imports

parent 2925dd32
No related branches found
No related tags found
No related merge requests found
......@@ -38,10 +38,12 @@ type DirectEventDispatcher struct {
observer.BaseListenable
}
// NewDirectEventDispatcher ac constructor of DirectEventDispatcher
func NewDirectEventDispatcher() observer.EventDispatcher {
return &DirectEventDispatcher{}
}
// Dispatch event directly
func (ded *DirectEventDispatcher) Dispatch(event observer.Event) {
if event == nil {
logger.Warnf("[DirectEventDispatcher] dispatch event nil")
......
......@@ -19,11 +19,14 @@ package dispatcher
import (
"fmt"
"github.com/apache/dubbo-go/common/observer"
"reflect"
"testing"
)
import (
"github.com/apache/dubbo-go/common/observer"
)
func TestDirectEventDispatcher_Dispatch(t *testing.T) {
ded := NewDirectEventDispatcher()
ded.AddEventListener(&TestEventListener{})
......
......@@ -51,7 +51,7 @@ func SetAndInitGlobalDispatcher(name string) {
if globalEventDispatcher != nil {
logger.Warnf("EventDispatcher already init. It will be replaced")
}
if dispatchers[name] == nil {
if dp, ok := dispatchers[name]; !ok || dp == nil {
panic("EventDispatcher for " + name + " is not existing, make sure you have import the package.")
}
globalEventDispatcher = dispatchers[name]()
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment