From 33054c9c245788f6f018494233be12611d8d598c Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Mon, 14 Jun 2010 11:43:04 +0200
Subject: return self

---
 lib/Net/Riak/MapReduce.pm | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'lib/Net/Riak/MapReduce.pm')

diff --git a/lib/Net/Riak/MapReduce.pm b/lib/Net/Riak/MapReduce.pm
index 5f76723..3d5e6b3 100644
--- a/lib/Net/Riak/MapReduce.pm
+++ b/lib/Net/Riak/MapReduce.pm
@@ -60,6 +60,7 @@ sub add {
     else {
         $self->add_bucket_key_data($arg, @_);
     }
+    $self;
 }
 
 sub add_object {
@@ -108,6 +109,7 @@ sub map {
         arg      => $options{arg} || [],
     );
     $self->add_phase($map_reduce);
+    $self;
 }
 
 sub reduce {
@@ -120,6 +122,7 @@ sub reduce {
         arg      => $options{arg} || [],
     );
     $self->add_phase($map_reduce);
+    $self;
 }
 
 sub run {
@@ -168,7 +171,7 @@ sub run {
     my $a = [];
     foreach (@$result) {
         my $l = Net::Riak::Link->new(
-            bucket => $_->[0],
+            bucket => Net::Riak::Bucket->new(name => $_->[0], client => $self->client),
             key    => $_->[1],
             tag    => $_->[2],
             client => $self->client
-- 
cgit 1.4.1