@@ -637,6 +637,25 @@ main = hspec
637637 it "dropInterval" (testDropInterval `shouldReturn` True)
638638#endif
639639
640+ -- Just some basic sanity tests for now
641+ let input = [[1,1] :: [Int],[2,2],[3,3],[4,4],[5,5],[6,6],[7,7],[8,8]]
642+ mustBe g inp out =
643+ S.toList (IS.concatPairsWith g S.fromList (S.fromList inp))
644+ `shouldReturn` out
645+ in do
646+ it "concatPairsWith serial"
647+ $ mustBe S.serial input [1,1,2,2,3,3,4,4,5,5,6,6,7,7,8,8]
648+ it "concatPairsWith wSerial"
649+ $ mustBe S.wSerial input [1,5,3,7,2,6,4,8,1,5,3,7,2,6,4,8]
650+ it "concatPairsWith mergeBy sorted"
651+ $ mustBe
652+ (S.mergeBy compare) input [1,1,2,2,3,3,4,4,5,5,6,6,7,7,8,8]
653+ it "concatPairsWith mergeBy reversed"
654+ $ mustBe
655+ (S.mergeBy compare)
656+ (reverse input)
657+ [1,1,2,2,3,3,4,4,5,5,6,6,7,7,8,8]
658+
640659 describe "Stream group and split operations" $ do
641660 groupSplitOps "serially"
642661