From 40bfb4af20d5c1eebb12761f8f18573b85a57d1c Mon Sep 17 00:00:00 2001
From: Dima Kossovich <koss@null.net>
Date: Sun, 12 Nov 2023 21:58:21 +0200
Subject: [PATCH] add tests for prefixpipe

---
 cover.cov                 | 242 +++++++++++++++++++-------------------
 coverage_badge.png        | Bin 2539 -> 2543 bytes
 pkg/pipe/pipe_test.go     |  63 ++++++++++
 pkg/pipies/filters.go     |   3 -
 pkg/pipies/pipies_test.go |   9 +-
 5 files changed, 188 insertions(+), 129 deletions(-)

diff --git a/cover.cov b/cover.cov
index 0fd7ccd..0a70fcb 100644
--- a/cover.cov
+++ b/cover.cov
@@ -61,11 +61,9 @@ github.com/koss-null/funcfrog/pkg/pipies/filters.go:43.25,45.3 1 1
 github.com/koss-null/funcfrog/pkg/pipies/filters.go:49.61,50.25 1 1
 github.com/koss-null/funcfrog/pkg/pipies/filters.go:50.25,52.3 1 1
 github.com/koss-null/funcfrog/pkg/pipies/filters.go:59.75,63.25 3 1
-github.com/koss-null/funcfrog/pkg/pipies/filters.go:63.25,64.15 1 1
-github.com/koss-null/funcfrog/pkg/pipies/filters.go:64.15,66.4 1 0
-github.com/koss-null/funcfrog/pkg/pipies/filters.go:67.3,72.28 4 1
-github.com/koss-null/funcfrog/pkg/pipies/filters.go:72.28,74.4 1 1
-github.com/koss-null/funcfrog/pkg/pipies/filters.go:75.3,76.14 2 1
+github.com/koss-null/funcfrog/pkg/pipies/filters.go:63.25,69.28 4 1
+github.com/koss-null/funcfrog/pkg/pipies/filters.go:69.28,71.4 1 1
+github.com/koss-null/funcfrog/pkg/pipies/filters.go:72.3,73.14 2 1
 github.com/koss-null/funcfrog/pkg/pipies/not.go:7.49,8.24 1 1
 github.com/koss-null/funcfrog/pkg/pipies/not.go:8.24,10.3 1 1
 github.com/koss-null/funcfrog/pkg/pipies/not.go:14.67,15.31 1 1
@@ -73,6 +71,123 @@ github.com/koss-null/funcfrog/pkg/pipies/not.go:15.31,17.3 1 1
 github.com/koss-null/funcfrog/pkg/pipies/not.go:21.82,22.37 1 1
 github.com/koss-null/funcfrog/pkg/pipies/not.go:22.37,24.3 1 1
 github.com/koss-null/funcfrog/pkg/pipies/reducers.go:9.72,12.2 2 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:12.69,13.19 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:13.19,15.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:16.2,16.17 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:16.17,18.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:19.2,19.18 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:19.18,20.40 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:20.40,22.4 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:23.3,23.14 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:26.2,30.13 5 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:39.3,41.14 2 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:41.14,43.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:45.2,46.15 2 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:46.15,46.40 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:48.2,48.38 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:48.38,49.49 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:49.49,51.4 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:53.3,53.9 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:56.2,59.44 4 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:62.73,66.16 3 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:67.9,68.50 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:69.9,70.50 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:73.2,73.15 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:73.15,74.28 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:74.28,76.4 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:77.3,77.28 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:77.28,79.4 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:80.3,80.15 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:80.15,81.9 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:83.3,85.7 3 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:88.2,88.11 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:92.68,93.62 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:93.62,95.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:96.2,96.62 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:96.62,98.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:100.2,100.62 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:100.62,102.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:103.2,103.62 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:103.62,105.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:107.2,107.62 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:107.62,109.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:110.2,110.62 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:110.62,112.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:115.2,115.64 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:115.64,117.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:118.2,118.64 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:118.64,120.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:121.2,121.21 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:124.38,126.25 2 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:126.25,128.3 1 1
+github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:129.2,129.16 1 1
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:6.50,9.33 2 0
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:9.33,10.42 1 0
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:10.42,13.5 2 0
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:14.4,14.20 1 0
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:23.62,26.33 2 0
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:26.33,27.42 1 0
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:27.42,30.5 2 0
+github.com/koss-null/funcfrog/pkg/pipe/collectors.go:31.4,31.20 1 0
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:10.36,12.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:22.58,24.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:33.48,34.36 1 1
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:34.36,36.3 1 1
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:48.60,50.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:57.40,59.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:64.87,66.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/constructors.go:69.41,71.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/functype.go:10.43,11.25 1 0
+github.com/koss-null/funcfrog/pkg/pipe/functype.go:11.25,14.3 2 0
+github.com/koss-null/funcfrog/pkg/pipe/functype.go:24.48,25.25 1 0
+github.com/koss-null/funcfrog/pkg/pipe/functype.go:25.25,27.3 1 0
+github.com/koss-null/funcfrog/pkg/pipe/functype.go:37.53,38.28 1 0
+github.com/koss-null/funcfrog/pkg/pipe/functype.go:38.28,40.3 1 0
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:15.46,17.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:20.52,22.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:27.60,29.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:32.53,34.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:38.42,40.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:43.40,45.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:48.30,50.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:53.28,55.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:59.47,61.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:64.28,66.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:69.31,71.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:75.49,77.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:81.38,83.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:86.48,88.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:91.58,93.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipe.go:96.52,98.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:15.53,17.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:20.59,22.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:27.67,29.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:32.32,34.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:37.30,39.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:43.42,45.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:49.41,51.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:55.54,57.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:61.45,63.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:66.55,68.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:71.65,73.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:76.54,78.2 1 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:13.15,16.33 2 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:16.33,17.42 1 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:17.42,20.5 2 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:21.4,21.20 1 0
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:33.20,36.33 2 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:36.33,37.42 1 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:37.42,40.5 2 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:41.4,41.20 1 0
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:51.98,53.22 2 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:53.22,55.3 1 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:56.2,57.19 2 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:58.9,59.14 1 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:60.9,61.29 1 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:62.10,64.27 2 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:64.27,66.4 1 1
+github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:67.3,67.13 1 1
+github.com/koss-null/funcfrog/pkg/pipe/yeet.go:13.38,15.2 1 1
 github.com/koss-null/funcfrog/internal/internalpipe/any.go:7.75,10.54 3 1
 github.com/koss-null/funcfrog/internal/internalpipe/any.go:10.54,11.37 1 1
 github.com/koss-null/funcfrog/internal/internalpipe/any.go:11.37,13.4 1 1
@@ -297,120 +412,3 @@ github.com/koss-null/funcfrog/internal/internalpipe/yeet.go:50.2,55.29 5 1
 github.com/koss-null/funcfrog/internal/internalpipe/yeet.go:55.29,56.37 1 1
 github.com/koss-null/funcfrog/internal/internalpipe/yeet.go:56.37,58.4 1 1
 github.com/koss-null/funcfrog/internal/internalpipe/yeet.go:62.33,66.2 3 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:12.69,13.19 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:13.19,15.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:16.2,16.17 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:16.17,18.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:19.2,19.18 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:19.18,20.40 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:20.40,22.4 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:23.3,23.14 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:26.2,30.13 5 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:39.3,41.14 2 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:41.14,43.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:45.2,46.15 2 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:46.15,46.40 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:48.2,48.38 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:48.38,49.49 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:49.49,51.4 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:53.3,53.9 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:56.2,59.44 4 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:62.73,66.16 3 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:67.9,68.50 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:69.9,70.50 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:73.2,73.15 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:73.15,74.28 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:74.28,76.4 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:77.3,77.28 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:77.28,79.4 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:80.3,80.15 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:80.15,81.9 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:83.3,85.7 3 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:88.2,88.11 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:92.68,93.62 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:93.62,95.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:96.2,96.62 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:96.62,98.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:100.2,100.62 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:100.62,102.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:103.2,103.62 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:103.62,105.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:107.2,107.62 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:107.62,109.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:110.2,110.62 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:110.62,112.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:115.2,115.64 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:115.64,117.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:118.2,118.64 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:118.64,120.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:121.2,121.21 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:124.38,126.25 2 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:126.25,128.3 1 1
-github.com/koss-null/funcfrog/internal/algo/parallel/qsort/qsort.go:129.2,129.16 1 1
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:6.50,9.33 2 0
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:9.33,10.42 1 0
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:10.42,13.5 2 0
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:14.4,14.20 1 0
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:23.62,26.33 2 0
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:26.33,27.42 1 0
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:27.42,30.5 2 0
-github.com/koss-null/funcfrog/pkg/pipe/collectors.go:31.4,31.20 1 0
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:10.36,12.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:22.58,24.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:33.48,34.36 1 1
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:34.36,36.3 1 1
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:48.60,50.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:57.40,59.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:64.87,66.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/constructors.go:69.41,71.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/functype.go:10.43,11.25 1 0
-github.com/koss-null/funcfrog/pkg/pipe/functype.go:11.25,14.3 2 0
-github.com/koss-null/funcfrog/pkg/pipe/functype.go:24.48,25.25 1 0
-github.com/koss-null/funcfrog/pkg/pipe/functype.go:25.25,27.3 1 0
-github.com/koss-null/funcfrog/pkg/pipe/functype.go:37.53,38.28 1 0
-github.com/koss-null/funcfrog/pkg/pipe/functype.go:38.28,40.3 1 0
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:15.46,17.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:20.52,22.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:27.60,29.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:32.53,34.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:38.42,40.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:43.40,45.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:48.30,50.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:53.28,55.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:59.47,61.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:64.28,66.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:69.31,71.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:75.49,77.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:81.38,83.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:86.48,88.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:91.58,93.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipe.go:96.52,98.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:15.53,17.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:20.59,22.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:27.67,29.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:32.32,34.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:37.30,39.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:43.42,45.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:49.41,51.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:55.54,57.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:61.45,63.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:66.55,68.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:71.65,73.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/pipenl.go:76.54,78.2 1 1
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:13.15,16.33 2 1
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:16.33,17.42 1 1
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:17.42,20.5 2 1
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:21.4,21.20 1 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:33.20,36.33 2 1
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:36.33,37.42 1 1
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:37.42,40.5 2 1
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:41.4,41.20 1 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:51.98,53.22 2 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:53.22,55.3 1 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:56.2,57.19 2 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:58.9,59.14 1 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:60.9,61.29 1 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:62.10,64.27 2 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:64.27,66.4 1 0
-github.com/koss-null/funcfrog/pkg/pipe/prefixpipe.go:67.3,67.13 1 0
-github.com/koss-null/funcfrog/pkg/pipe/yeet.go:13.38,15.2 1 1
diff --git a/coverage_badge.png b/coverage_badge.png
index 648a80e80ebe066c2ae2ee5d6a8815a592c60075..fb42c16a0c1352c859ef5b058a875678c23c63c7 100644
GIT binary patch
delta 2515
zcmV;^2`u*O6Ymp{Hh-i^L_t(&f$f=XP*m3$$A5S4y$ibwTwZq(M5t)gj-tklv7#1q
zWQdtmqK$wSbr>f)Q&LSv+r%o^$&6-dtf97@F=lKrnW=H2lN!e_j%g+}lgSH{n4l&N
zAPDG+yTC3lyUX2sPd^Yh0Rb`jAZh!bxgYM`bAHcr&i~x=a(`EP<dH|BoKEKpk|dQ1
zAzb`l_blHp|8-yE3vdfKu6r7vRh&-e3qpu(LWujC)DKzXpzl&8*rp~=MlnsZ^nPda
zL)SPkbU;F^RsKKCet(S{L&2$xqhx-t8c%&VCPQUeM$<F`fdGL(;ClsBRh787IQ)J;
zx~_jO)_BoKeSfG(3YwZsNB>O(V>ew>ljt+L(arvQ&Sg|XtyU`~B_%9exR8#H4(xV2
zLI}>BIm7w$=kF;{baXT&B_%9auz=3aPEt}*sIRZ*l~-QD<MG^c;^Rrf^<klFEyWp6
z;R)U#G0Mfkub!dK{{aBMnf4bJBrZo6-wfz&7a!$%;D0L5Og)H76lwM>UcOqzCI3eN
z?3#XrzqeG=&|5cZE~6T{Wy=<X5R{gd5(<SdO_QvwEb{X51~o!eRWwb*>-CN}S~qRl
zL^vE~&6+jnx{eTn!oosqHe005SU5u^%QA_HiF9;yU>L@T<s?ZWE-ns9lJNO_ckoqJ
zB|bhLkAKHA=(n-(hqBUaKcXyS2W$SCOSkCc;R*TdF8nhaYUg7L1Kn@3zxFxata~+5
zCvkQZE-j78)>-`G<PsisE#<KXH&EyMkZG}V2>3#Laq}XI!!l}rjA-bD2@{w-dp7IV
zts^EThS=Cx0Q`PGufP6!<i4PwfR!s((%#-qe1CjAFTL~<&CSh&Sn28M%$+-zb?erl
zX&RCw0dV2M1yof<Rn=iRbLY;*<#KWO@L>Sr;^H`P-~bgB6@)?|7A;!D>eZ`pyWOOv
zrE%oQ5$fvdIDY&%uf6sfD^{$arKN>^`}T40;6Xy65Qbr3x7*pje?M()Z2;uw=d)(b
z8h_f`+lh^hMV4i@ZrwT}|89m(w$9|Mn^%w?=q6rO`MmR8bX_MSdJ0W_UjTxrWDCjj
zqXyNBG8}XVe8fGV5SDt0HXH~cSeL$?KfLo>WS4Z;fj*+46DLljsi_HBmLtzB77JFZ
z6;)L+O_S8rREmm<*tl^cy}iBU=H~L`lYdXLbLY-MthBT=nwy&=tlKedHX8sgmupx~
zWo0FY4<DwcriMTuz~aS=Id|?Hfj|JK(@9ZL5t}w`A`}XdnVCsdRTVpS>;Ryrr-uz2
zHei}2F)=ZemzNU^1_3B3DPh^NWz^Kvkdl%@ad9!_<>mN%J~A>g*t>Tx$;rv1@_$D&
zwAs_hlqoaN+7j{W9oQ1A=!Q<T9*YnItLc`UN;dHv?ZH-#Ufs*5T^DHcH<9FUF)d~;
zi?m1i-2D+b+Cpx4uG5#`p(Nv1SS?YUxn6^}|K`0J8V-k%Wf@5t7!}KxFXxFTo<LC)
znwy*1vu6+4+1Y&d*=Ja-R-&V$xqo=^BAJ<)Sglq<p-_Zn7zUCgMOZ^M5(l8Rww478
z7V!4lZ<Cjo$MerW55Ux^Q&Clw-Me=qNfM@MlAfL(VZQa&Ti9&2NX%u+mXVj2M{;s9
zcDtR+moFoPh{U#7EF>i*MP{DS_(R(;^uE6DQ{MRWD2M0$lUt!S3}KLBPk+VJ=SIka
zz3*<tcdHwVB(dzrk5O50l;Zbi5>i9#_(vHl7Z%g%Y36jpF%A}-;CJUM*!t5KxY+U`
zH+!zLbI!{=bMa^QW@uAW6PcNr#KgqV-QCTpQ>Qp~>==s{Euy%%7$F4VaCneW(b3TW
zn5H?Xk=L$WBP%Nlo6SaFUw_}QgJ(Dnz}d5BDK9UlwY8P5t}brfx`m=B7=}SZLj#8n
z9g36<g+h^8z;3rkp6BG`P*PID?%lg-Y;0ud(xog}vIHRnhG7gExVQ7Z8-FxIWrxJy
z>VMDC4-R6t+fghEr`Fff9&SZg1ad}*q%11{?|aXp>;1T*CUMR9H-GM=FZttzDlArs
z{Fy8Gvh5Ont&M5+2if2JYx*P~J8ji~gb?N(xma#DV(4|_#tmv~YpJNHz~OLUx7%?#
zooJdCX~dN)SC}<x77oY2Tt9#Qd>R@W2nK_LSS>9r)Ya9odGlthR%@gKa&vRZ%E}s*
zbLGkvVq;@jyLK(7Pk*0AmSuzx)Ya87efo3~5)udog9L*?va_=z>~F`9i;Lsx)vI)L
zbdZvg!i*U+B4sXLzD!O|4%yk+Xqv|2#ft$(<&WjEPn2=wm_%oX+4<Oh-uUDwhBB}j
zoS85`Qf}VlpCCyVTD?~hLLl3~K1s%wDpQ<RLCvKDNLJ_xc7K!LjKh{>C2WK-4P)52
z(yCRfMqFh>p%5E4ZltiV5U<x88J#CioZ!9p-Xk0ilb@eYSy>tF?d@oqMrCCsot>R`
zunfas`}Xb3nKK8k*Bd#uR99Ey@pwk%6ciLtT3Sk3Ss99=M0hzlIaE|s(ACvNVqzjq
zO-=0Ew~v!2Pk*v{_3Cfl7+L1U7hgn{WfVoBt*s5e-_M~#hcFC-dGqG6e*Jn()8yli
zKjxu_9^&bzpB|AvRKtCo-#ldxvlAAQWSzjdFHiBOPxcU<G0@e=9{v!k5`|Cq60fAN
z=gd=FPI!l}_lf{4b**ATU>dJ__hL~ca`n~xeEtT4W`BSWE?wZw@S!_m0!WWP{`iQ7
z3L)t3?j{%v;&Qp@>+7SZrzi5p0`&Fu(cj-sa&j_mw;N5<P*wE~mT8*!d_KbAFfNyi
z&dyE@!$8wCWLX}S)7#riPfrg{r!%rc1_%a&`2BuTQc~#d?#3_-5)u+{yWOOwrVfhT
z)zw96YJVzTuNPg{u~;m`$HxN@2n6Wu?FC@@^5ra9vV`jD>Jj;4F_i0e9N`3RcDj+Y
zejJ%He4TpdCpz)b$vA9wu6MLzpDbaGAAB4Mc}$Fez@9Pi5`}J=C|wRz#Y&I01AF?N
zQ$K)IR8%yk1K;h9jm2{3IY<bBX_~{XFC(!m7JthibG{4bwoKEEtij(UZdFwkLI`wS
zXVRoe?Ao;puh%<f{&0p01I)0%VwD)Kni&RR2xO}iG5T&2VGw{t8M%zKa^=eL^C9v+
z$uvzeGBVJ0o%;IvfsKqZO0Nyk{r*4n+fsxOZXorpCI5>hgrKpp5lNDWiHRBUcr{x6
zaZDjex}gBag%I2BcP{r+k|YgU_wUu9@nWcibX?JO{aHm(5JHsjKmMkESB(Qh-AK}L
dhtcuee*hx9B3?cRxaI%=002ovPDHLkV1hI}+Rp$0

delta 2511
zcmV;=2{88W6YCR@Hh-W=L_t(&f$f=VY!ufShM(D)S@vRkeBCuR#tw!6YA_HGLD*0m
z1a+uV94Nj(4ah}+RJV`_+LQpMLV~D-8khD5Axdi+sRRYo0F6{p(kdaUNa7L_gA>Iz
zc8p;$yI$}5vb*fgoc=&8v5k#Me&DoyrTMWlXP)mn-+ShqIe)X#(@#G=#^G?hBuP@4
z5W>m-_0aPD<h@54Uw})%v9P=O1;ycTyd;F!B7}IPNqw6&3Tl@s!4@@n0*YZ6Wsf?W
zZ@Wf;p?4(2D&_yv>^Ik_F%%riC`#sAtI<@$5g97WGMc6l2m}ZO0^ca0s;b1r#o_n+
z35Ubqh&5U?RDTT>NkLPS>AZatLH{-}ibjm0;SOCVA|m~+X=)OEdN*O?_Cx0~tf6MJ
znbOiy=FOW&XJ;oin++iZXU?4A+_`fP706<-P+D5b+_`h{dcCBiq|n&d$g8iuireje
z=)^~p?pMP?=PF7veu_JIgTygTs=s)idjACg4o?3oiGOA%T_HC~W1JlLVl)5ldKZA_
zCsm^|hBR9iuUxI-vj0N>c1$_KpWA9^>a8C(mthUvv}qGU2+GRJ2!%ozhCx<V7Ww)4
z{W_tlDw?L@@py(Dt?SpXClZNJTwF{z97YI1VPPRwt2KJhNH_x}%QA_HiF9^$qU-vQ
z?IcMeE`Kf#Ns{pSe1rI^suCX`kK66;cWos6fvhy^W0YrXqxcWGbPF#}jV)kj;qO^n
zHwQ!L)ck!nA6$J8lM3I<UdfO1c2VbDMDm!iOfXO5M<*8Wlyf1^Jh_&7-v>;Nok74C
z;<KBVQ0%5*>oKIEW5<qV`t<3nUcH)_m>6PXV}Akg`~AG}#v9S!OO`BQ*|KGHbaW6O
zAJ4&q2Wf3>?Z-+_PiN-LnXF#D8coxXBng1?=g*_6Dypj9moszbOq@<9hYueHATBPB
z0|yRJSy@Ra6e2G#j}<Fc;BvW0OH1R(kt5XC*K_RHF<yWDb(St&N?ThS`}Xaly1JTB
zD1U^m>)32I_V3?MdwV+o1qB5Z7Z=mf(Lro%EV3-KdGqEW`42L5g82!)xY>a8csKE?
z%BS9U35UaESSHfa_Zbb!zet*G2Eb#qVHOsI5RB37bO(IIJ+2Uuda>wsgb=Jw-^y?P
z`69AYdf-4G($I0^#?jK!f-K9?b0(7svwzu)s;U@<L27C$MMXudTepth-d=KZbJ?(A
z1KYQ6@5f3@OQW^5HOjgh(`vN>;B-3g%h|PS7l#iYrna`0Kp?>U`SUq@_AG%w0Efdt
zQBe`=*RLlO3Xz$aNmW%9+qP{3pr@yYwQJX67zQyhF;rAk5DW$ZC@n2z(V|7v)_>NL
zl9ED6NeLAd75IEUGBPsQyLT_i$;rd=hcmR*-OR*^Q_<QJ@rOIHCYTB9VJzWTgb=84
z_l#Nj_y+#=*-3;DwEJ5~vOAd^Gm|{+`+Vy9kQ{9uH{93hOK?+~@iWY(F`T(xi|6*u
zhch%1i6F}|l5{8d;>C+uxpF0nqJPlZ+RE<TyUEVZ=95o8!E82Tu~@it=@OZlnV8LH
zLZMKUrRzG9Bt=;RH53P+uC9)`bLaBTJMWO6pU<8>djOa;X%eccvUBH7BuT<B4ARrn
zqs-H%Ph+)OqcImPT10++KFP_+*laegT)Bb}A{yIdGLe*&6rFj7;}7h^z<=M3eIN7Y
z$FFgC)<3uvYDX73DYjJHeJ+H2ukG5bU!al9(Z)@f(*+SV#J0D}SvIePYwlJ~H65jT
z$#H&lu9D5)eThqLA8@nhI@@Qw!t<AY@NkB<w6u_!nMq7c4Bg$`oIH7wqeqXDmzPIL
zNeMy-B9TZxqbwE+0ES`o>wn~zUw%neRu)#PmA<~dL9vG70KEP7+f-CkaP8VPy1Kf!
zb?X+2qM++KO-)T4I&>)7HWUg)X91hd7CoPnlS64~DLZ%Wq`A47g$oz5V8H@}5a_zz
zZ{Xg|`$7D#YG4gzyTl(Gf6Z$bs<GK@C?<uIYwGBTTtk=y5)vCH?tf;yJe4h{OHe22
z2mwgoO8T7Np0C1WmMC~)DWA7r#;>(A+4dy+TYpZU<YT+F29OZK7?g|YZYKsFH*VaZ
zuC9*C%1Z2ZJ2smQhr@xUY0*wJG&C@6+BEF;J9GV<Idf=gY9bg6_G7iRwNYPR&&G`#
zF`LcN0_5iAl9iP;EPtn=p@G=gSXQlC#i>)LkYyPm1oidxOqnu;goFfw!63n4knHU2
zDEq7N<Kp7Ddi5%uot>nlq%d{r)M%S4SFVtglS6iPHkzg}fBt-cVfiCDY~y6?IR=*O
z2-~08&zl!tLs!DclERDMc?EkYfz59fqf7_^_wJLeU>h%EO@EasNvovx@&P0>^aQ&}
zaKvFvG854w7`lGnxYF|F%ZFTLL!l7s)~%zkun>>O6CIt$k00m#_unTHiBM2bKzVsN
z9UUELn#QhOyYPCwgIKz*vvuoMX3Us@$K#1^TWV@*aJ${Za+WMvLRncE<>loliW24J
z<m6CUSxHw{7k`O~iL|t|uy5Z!PMkQwiWMvFJu$M(%P+r-EXyd0LVJ5Ve!rhXhYq3Z
zI<scYV$GU07>2<|AAQ8^*|T}>x#x!D57hlW&TpK!o9PMjNHUM*?B^%>-NoHlG6ZRs
z$2dCg0={4;k}O5r@2OwUMejY%Lg#YE1}5_-&t6QbM1O901wWj#mY@;f!sYY)C30v`
zOaSTGXP+I?P$2}}-Q5I(L7Yw}eSLlO^z=lZSb)C1K5pN>O>%NFE|&{U(@<4)5X&$O
zd_EtMNCc<TiP!5z*L5^aLzd-XIlaBT^z`)La5$oG$N<4$5Wn9~N=gdd-QDQAPC`Ng
zE|-hc)PK}|vAepuNKH+}<M9v<hcTH<#K*@25C{b5?d=6%@#4iSSg?SanwlZ`BQccg
zHtdlEZhBov+HLHaGDx5Y1>TEcOan?3J4r#+?rljzZUa3auw~qNh(fmvlrB4}Vy4I3
zi7kEb)DIvP6%~zW!*}<^#$+124-!IP7{-0qmw%yHCX=b3IbVl!SB7Ck*Wj-cx2mcN
zAq3%YnDOJsvt!2&JRZ-8`S&wa=wL(yCbPr?(i*Wu1O#AGhHfJ*TefWUe29ERG7N)^
zj10ozFpZ6kcV1+aVX8JjkNW@6uSyX@xPa6Lw)`)a5Q66BW+X`>CMIUc?bUGij|xfB
z4M+tzCWP4XsB?Lgk|e3$y8o~SjTS>Cq+?1r9DYGj6oe3^{Et7WUst2RP#2PP%&vF-
Z@;^7SAXnPV?I{2N002ovPDHLkV1leV-uM6j

diff --git a/pkg/pipe/pipe_test.go b/pkg/pipe/pipe_test.go
index 5a41241..f022886 100644
--- a/pkg/pipe/pipe_test.go
+++ b/pkg/pipe/pipe_test.go
@@ -1016,6 +1016,69 @@ func TestYetiSnag(t *testing.T) {
 	}
 }
 
+// prefixpipe
+
+func TestPrefixMap(t *testing.T) {
+	res := pipe.Map(
+		pipe.Slice([]int{1, 2, 3}),
+		func(x int) string {
+			return strconv.Itoa(x)
+		},
+	).Do()
+	require.Equal(t, []string{"1", "2", "3"}, res)
+}
+
+func TestPrefixMapNL(t *testing.T) {
+	t.Parallel()
+
+	res := pipe.MapNL(
+		pipe.Func(func(i int) (int, bool) {
+			return []int{1, 2, 3}[i], true
+		}),
+		func(x int) string {
+			return strconv.Itoa(x)
+		},
+	).Take(3).Do()
+	require.Equal(t, []string{"1", "2", "3"}, res)
+}
+
+func TestPrefixReduce(t *testing.T) {
+	t.Parallel()
+
+	t.Run("common", func(t *testing.T) {
+		res := pipe.Reduce(
+			pipe.Slice([]int{1, 2, 3, 4, 5}),
+			func(s *string, n *int) string {
+				return *s + strconv.Itoa(*n)
+			},
+			"the result string is: ",
+		)
+		require.Equal(t, "the result string is: 12345", res)
+	})
+	t.Run("zero_res", func(t *testing.T) {
+		res := pipe.Reduce(
+			pipe.Slice([]int{1, 2, 3, 4, 5}).
+				Filter(func(x *int) bool { return *x > 100 }),
+			func(s *string, n *int) string {
+				return *s + strconv.Itoa(*n)
+			},
+			"the result string is: ",
+		)
+		require.Equal(t, "the result string is: ", res)
+	})
+	t.Run("single_res", func(t *testing.T) {
+		res := pipe.Reduce(
+			pipe.Slice([]int{1, 2, 3, 4, 5}).
+				Filter(func(x *int) bool { return *x == 5 }),
+			func(s *string, n *int) string {
+				return *s + strconv.Itoa(*n)
+			},
+			"the result string is: ",
+		)
+		require.Equal(t, "the result string is: 5", res)
+	})
+}
+
 // helping functions
 
 func wrap[T any](x T) func() T {
diff --git a/pkg/pipies/filters.go b/pkg/pipies/filters.go
index 5aa0022..ed79909 100644
--- a/pkg/pipies/filters.go
+++ b/pkg/pipies/filters.go
@@ -61,9 +61,6 @@ func Distinct[T any, C comparable](getKey func(x *T) C) pipe.Predicate[T] {
 	var mx sync.Mutex
 
 	return func(y *T) bool {
-		if y == nil {
-			return false
-		}
 		key := getKey(y)
 
 		mx.Lock()
diff --git a/pkg/pipies/pipies_test.go b/pkg/pipies/pipies_test.go
index 541f68a..777809f 100644
--- a/pkg/pipies/pipies_test.go
+++ b/pkg/pipies/pipies_test.go
@@ -116,14 +116,15 @@ func Test_Not(t *testing.T) {
 func Test_Distinct(t *testing.T) {
 	t.Parallel()
 
-	getKey := func(x *int) int { return *x }
+	z, o, w, r, fv := 0, 1, 2, 3, 5
+	getKey := func(x **int) int { return **x }
 	predicate := Distinct(getKey)
-	filtered := pipe.Slice([]int{1, 2, 3, 3, 2, 2, 1, 5, 2, 3, 1}).Filter(predicate).Do()
+	filtered := pipe.Slice([]*int{&o, &w, &r, &r, &w, &w, &o, &fv, &w, &r, &z}).Filter(predicate).Do()
 
 	found := make(map[int]struct{})
 	for _, f := range filtered {
-		_, ok := found[f]
+		_, ok := found[*f]
 		require.False(t, ok, "Distinct element is duplicated")
-		found[f] = struct{}{}
+		found[*f] = struct{}{}
 	}
 }