check errors

Author: raulb

source/logrepl/cdc_test.go

@@ -519,10 +519,12 @@ func TestCDCIterator_NextN(t *testing.T) {
 			go func() {
 				recordsTmp, err := i.NextN(ctx, 5)
 				if err != nil {
-					recordsCh.Send(ctx, nil)
+					err = recordsCh.Send(ctx, nil)
+					is.NoErr(err)
 					return
 				}
-				recordsCh.Send(ctx, recordsTmp)
+				err = recordsCh.Send(ctx, recordsTmp)
+				is.NoErr(err)
 			}()
 
 			recordsTmp, ok, err := recordsCh.RecvTimeout(ctx, 5*time.Second)