Corrects the libraries panic behaviors

This library will no longer swallow panics with this change

Closes GH-5

Author: benjivesterby

scaler.go

@@ -65,7 +65,6 @@ func (s Scaler[T, U]) Exec(ctx context.Context, in <-chan T) (<-chan U, error) {
 	}
 
 	go func() {
-		defer recover()
 		defer close(out)
 
 		wg := sync.WaitGroup{}
@@ -137,7 +136,6 @@ func (s Scaler[T, U]) layer2(ctx context.Context, in <-chan T) <-chan U {
 	out := make(chan U)
 
 	go func() {
-		defer recover()
 		defer close(out)
 
 		timer := time.NewTimer(s.Life)

stream.go

@@ -44,7 +44,6 @@ func Intercept[T, U any](
 	out := make(chan U)
 
 	go func() {
-		defer recover()
 		defer close(out)
 
 		for {
@@ -59,9 +58,6 @@ func Intercept[T, U any](
 				// Executing this in a function literal ensures that any panic
 				// will be caught during execution of the function
 				func() {
-					// TODO: Should something happen with this panic data?
-					defer recover()
-
 					// Determine if the function was successful
 					result, ok := fn(ctx, v)
 					if !ok {
@@ -139,7 +135,6 @@ func FanOut[T any](ctx context.Context, in <-chan T, out ...chan<- T) {
 				// Closure to catch panic on closed channel write.
 				// Continue Loop
 				func() {
-					defer recover()
 					select {
 					case <-ctx.Done():
 						return