summaryrefslogtreecommitdiff
path: root/dedumi.hs
diff options
context:
space:
mode:
Diffstat (limited to 'dedumi.hs')
-rw-r--r--dedumi.hs6
1 files changed, 4 insertions, 2 deletions
diff --git a/dedumi.hs b/dedumi.hs
index aa682f1..4215026 100644
--- a/dedumi.hs
+++ b/dedumi.hs
@@ -15,6 +15,7 @@ import Data.Function
import GHC.Prim (RealWorld)
import GHC.TypeLits
import Lens.Micro
+import qualified Streamly.Data.Fold as F
import qualified Streamly.Data.Stream as S
import System.Environment
@@ -42,10 +43,10 @@ insert' :: (KnownNat b, KnownNat f) => CuckooFilter RealWorld b f ByteString ->
insert' f x =
let y = B.take (umiLength + extraHashBases) (x ^. _1 . nucs) <> B.take (umiLength + extraHashBases) (x ^. _2 . nucs)
in member f y >>= \case
- True -> pure True
+ True -> pure False
False ->
insert f y >>= \case
- True -> pure False
+ True -> pure True
False -> error "filter full"
main :: IO ()
@@ -57,4 +58,5 @@ main = do
parse p1 p2
& S.filterM (insert' f)
& fmap trim
+ -- & S.fold (F.drainMapM print)
& unparse p3 p4