From 8d6b4af66a3f79580ec7c3694fb263149c255d55 Mon Sep 17 00:00:00 2001
From: Sebastiaan Koppe <mail@skoppe.eu>
Date: Mon, 29 Jul 2024 17:13:57 +0200
Subject: [PATCH] Add test for nextTransform

---
 tests/ut/concurrency/sequence.d | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/tests/ut/concurrency/sequence.d b/tests/ut/concurrency/sequence.d
index 6f255db..8fd4186 100644
--- a/tests/ut/concurrency/sequence.d
+++ b/tests/ut/concurrency/sequence.d
@@ -125,6 +125,16 @@ import unit_threaded;
     [1,2,3].sequence.flatMap((int i) => just(i*3)).toList().syncWait.value.should == [3,6,9];
 }
 
+@("nextTransform")
+@safe unittest {
+    static struct Transformer {
+        auto setNext(Sender)(Sender s) {
+            return s;
+        }
+    }
+    just([1,2].sequence).flatten.nextTransform(Transformer()).toList.syncWait.value.should == [1,2];
+}
+
 @("scan")
 @safe unittest {
     [1,1,1,1].sequence.scan((int i, int acc) => acc + i, 0).toList().syncWait.value.should == [1,2,3,4];