Commit 5f17f834 authored by Steven Allen's avatar Steven Allen

tests: remove t.Fatal from goroutines

parent 6d166d40
...@@ -40,7 +40,9 @@ func (tp *provider) TestBasicPubSub(t *testing.T) { ...@@ -40,7 +40,9 @@ func (tp *provider) TestBasicPubSub(t *testing.T) {
for { for {
err := apis[1].PubSub().Publish(ctx, "testch", []byte("hello world")) err := apis[1].PubSub().Publish(ctx, "testch", []byte("hello world"))
if err != nil { if err != nil {
t.Fatal(err) t.Error(err)
cancel()
return
} }
select { select {
case <-tick: case <-tick:
......
...@@ -423,11 +423,13 @@ func (tp *provider) TestAdd(t *testing.T) { ...@@ -423,11 +423,13 @@ func (tp *provider) TestAdd(t *testing.T) {
for evt := range eventOut { for evt := range eventOut {
event, ok := evt.(*coreiface.AddEvent) event, ok := evt.(*coreiface.AddEvent)
if !ok { if !ok {
t.Fatal("unexpected event type") t.Error("unexpected event type")
continue
} }
if len(expected) < 1 { if len(expected) < 1 {
t.Fatal("got more events than expected") t.Error("got more events than expected")
continue
} }
if expected[0].Size != event.Size { if expected[0].Size != event.Size {
...@@ -453,7 +455,7 @@ func (tp *provider) TestAdd(t *testing.T) { ...@@ -453,7 +455,7 @@ func (tp *provider) TestAdd(t *testing.T) {
} }
if len(expected) > 0 { if len(expected) > 0 {
t.Fatalf("%d event(s) didn't arrive", len(expected)) t.Errorf("%d event(s) didn't arrive", len(expected))
} }
}() }()
} }
......
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