diff --git a/pkg/pipe/firehose.go b/pkg/pipe/firehose.go
index fb0894e..831e6d6 100644
--- a/pkg/pipe/firehose.go
+++ b/pkg/pipe/firehose.go
@@ -111,7 +111,7 @@ func Send[T any](ch chan T) Forward[T] {
 		case ch <- t:
 			return nil
 		default:
-			return fmt.Errorf("channel is full, dropping %v", t)
+			return fmt.Errorf("pipe.Send: channel is full, dropping %v", t)
 		}
 	}
 }