Merge pull request #126 from iopred/docs

Fix for single threaded job queue feature.
This commit is contained in:
Bruce 2016-02-20 01:05:15 -06:00
commit e244177d27
2 changed files with 5 additions and 2 deletions

View file

@ -196,11 +196,13 @@ func (s *Session) AddHandler(handler interface{}) func() {
// handle calls any handlers that match the event type and any handlers of
// interface{}.
func (s *Session) handle(event interface{}) {
s.initialize()
s.handlersMu.RLock()
defer s.handlersMu.RUnlock()
if s.handlers == nil {
return
}
handlerParameters := []reflect.Value{reflect.ValueOf(s), reflect.ValueOf(event)}
if handlers, ok := s.handlers[reflect.TypeOf(event)]; ok {

View file

@ -88,6 +88,7 @@ func (s *Session) Open() (err error) {
s.Unlock()
s.initialize()
s.handle(&Connect{})
return