fix: remove unnecessary ctx.Err() check (#4)

* improve coverage for bridge * remove unnecessary code
bradfair · Jan 21, 2024 · fcae3ac · fcae3ac
1 parent 175fbb6
commit fcae3ac
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/bridge.go b/bridge.go
@@ -47,9 +47,6 @@ func bridgeInputStream[Input any](ctx context.Context, inputs <-chan Input, out
 			if !ok {
 				return
 			}
-			if ctx.Err() != nil {
-				return
-			}
 			out <- val
 		}
 	}