Fix map/filter Subscribable combinators.

rakudo · Nov 2, 2013 · 42f2a5f · 42f2a5f
1 parent c95b6d9
commit 42f2a5f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/vm/jvm/core/Threading.pm b/src/vm/jvm/core/Threading.pm
@@ -781,7 +781,7 @@ my class SubscribableOperations is repr('Uninstantiable') {
                 my $sub = self.Subscribable::subscribe(|c);
                 my $ssn = $!source.subscribe(
                     -> \val {
-                        if (filter(val)) { self!next(val) }
+                        if (&!filter(val)) { self!next(val) }
                     },
                     { self!last(); },
                     -> $ex { self!fail($ex) }
@@ -803,7 +803,7 @@ my class SubscribableOperations is repr('Uninstantiable') {
                 my $sub = self.Subscribable::subscribe(|c);
                 my $ssn = $!source.subscribe(
                     -> \val {
-                        self!next(mapper(val))
+                        self!next(&!mapper(val))
                     },
                     { self!last(); },
                     -> $ex { self!fail($ex) }