@@ -637,6 +637,25 @@ main = hspec
637 it "dropInterval" (testDropInterval `shouldReturn` True)
637 it "dropInterval" (testDropInterval `shouldReturn` True)
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]]
643+ S.toList (IS.concatPairsWith g S.fromList (S.fromList inp))
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"
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"
657+ [1,1,2,2,3,3,4,4,5,5,6,6,7,7,8,8]
640 describe "Stream group and split operations" $ do
659 describe "Stream group and split operations" $ do
641 groupSplitOps "serially"
660 groupSplitOps "serially"