Commit 5b07254a authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 9de249df
...@@ -528,7 +528,7 @@ func (t *T) RxEvent(event interface{}) { ...@@ -528,7 +528,7 @@ func (t *T) RxEvent(event interface{}) {
t.streamTabMu.Unlock() t.streamTabMu.Unlock()
if ch == nil { if ch == nil {
t.fatalfInNonMain("test is no longer running") t.fatalfInNonMain("test failed")
} }
// TODO it is possible to empirically detect here if a test incorrectly // TODO it is possible to empirically detect here if a test incorrectly
...@@ -651,7 +651,7 @@ func (t *T) xget1(stream string, eventp interface{}) *Msg { ...@@ -651,7 +651,7 @@ func (t *T) xget1(stream string, eventp interface{}) *Msg {
reventp := reflect.ValueOf(eventp) reventp := reflect.ValueOf(eventp)
if reventp.Type().Elem() != reflect.TypeOf(msg.Event) { if reventp.Type().Elem() != reflect.TypeOf(msg.Event) {
t.queuenak(msg, "unexpected event type") t.queuenak(msg, "unexpected event type")
t.Fatalf("%s: expect: %s: got %#v", ch.name(), reventp.Elem().Type(), msg.Event) t.Fatalf("%s: expect: %s: got %T %v", ch.name(), reventp.Elem().Type(), msg.Event, msg.Event)
} }
// *eventp = msg.Event // *eventp = msg.Event
...@@ -776,8 +776,9 @@ func (t *T) FailNow() { ...@@ -776,8 +776,9 @@ func (t *T) FailNow() {
bad += fmt.Sprintf("noone is sending\n") bad += fmt.Sprintf("noone is sending\n")
} else { } else {
bad += fmt.Sprintf("there are %d pending sender(s) on other channel(s):\n", len(sendv)) bad += fmt.Sprintf("there are %d pending sender(s) on other channel(s):\n", len(sendv))
//bad += fmt.Sprintf("the following send(s) are pending:\n"
for _, __ := range sendv { for _, __ := range sendv {
bad += fmt.Sprintf("%s:\t%T %v\n", __.ch.name(), __.msg.Event, __.msg.Event) bad += fmt.Sprintf("%s\t<- %T %v\n", __.ch.name(), __.msg.Event, __.msg.Event)
} }
} }
......
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