SendCtx utilization

yajunzhang · Feb 24, 2020 · 5c07e48 · 5c07e48
1 parent 3b8f824
commit 5c07e48
Show file tree

Hide file tree

Showing 3 changed files with 74 additions and 79 deletions.
diff --git a/observable.go b/observable.go
@@ -297,7 +297,7 @@ func runPar(ctx context.Context, next chan Item, iterable Iterable, operatorFact
 				case item, ok := <-observe:
 					if !ok {
 						if !bypassGather {
-							gather <- Of(op)
+							Of(op).SendCtx(ctx, gather)
 						}
 						return
 					}