Commit b56b4169 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent bec06159
...@@ -565,18 +565,6 @@ func (t *T) RxEvent(event interface{}) { ...@@ -565,18 +565,6 @@ func (t *T) RxEvent(event interface{}) {
ch.Send(event) ch.Send(event)
} }
/*
// chanForEvent returns channel corresponding to stream where event has to be delivered.
// must be called under streamTabMu.
func (t *T) chanForEvent(event interface{}) Chan {
stream := "default"
if t.routeEvent != nil {
stream = t.routeEvent(event)
}
return t.chanForStream(stream)
}
*/
// chanForStream returns channel corresponding to stream. // chanForStream returns channel corresponding to stream.
// must be called under streamTabMu. // must be called under streamTabMu.
func (t *T) chanForStream(stream string) Chan { func (t *T) chanForStream(stream string) Chan {
...@@ -851,8 +839,10 @@ func Verify(t testing.TB, testf func(t *T)) { ...@@ -851,8 +839,10 @@ func Verify(t testing.TB, testf func(t *T)) {
} }
/*
// ---- misc ---- // ---- misc ----
func panicf(format string, argv ...interface{}) { func panicf(format string, argv ...interface{}) {
panic(fmt.Sprintf(format, argv...)) panic(fmt.Sprintf(format, argv...))
} }
*/
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