Commit e4221444 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent c75eddb0
...@@ -253,8 +253,11 @@ func (t *T) queuenak(msg *_Msg, why string) { ...@@ -253,8 +253,11 @@ func (t *T) queuenak(msg *_Msg, why string) {
} }
// XXX doc; naming // SetEventRouter tells t to which stream an event should go.
// XXX document routeEvent requirements //
// It should be called not more than once.
// Before SetEventRouter is called, all events go to "default" stream.
// XXX naming
func (t *T) SetEventRouter(routeEvent func(event interface{}) (stream string)) { func (t *T) SetEventRouter(routeEvent func(event interface{}) (stream string)) {
t.mu.Lock() t.mu.Lock()
defer t.mu.Unlock() defer t.mu.Unlock()
......
Markdown is supported
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