summary refs log tree commit diff
path: root/t/10_async.t
diff options
context:
space:
mode:
Diffstat (limited to 't/10_async.t')
-rw-r--r--t/10_async.t88
1 files changed, 0 insertions, 88 deletions
diff --git a/t/10_async.t b/t/10_async.t
deleted file mode 100644
index 9e88280..0000000
--- a/t/10_async.t
+++ /dev/null
@@ -1,88 +0,0 @@
-use strict;
-use warnings;
-
-use Test::More;
-use JSON::XS;
-use Test::Exception;
-use AnyEvent::Riak;
-use YAML::Syck;
-
-plan tests => 5;
-
-my ( $host, $path );
-
-BEGIN {
-    my $riak_test = $ENV{RIAK_TEST_SERVER};
-    ($host, $path) = split ";", $riak_test if $riak_test;
-    plan skip_all => 'set $ENV{RIAK_TEST_SERVER} if you want to run the tests'
-      unless ($host && $path);
-}
-
-my $bucket = 'test';
-
-ok my $riak = AnyEvent::Riak->new(
-    host => $host,
-    path => $path,
-    w    => 1,
-    dw   => 1
-  ),
-  'create riak object';
-
-{
-    my $cv = AnyEvent->condvar;
-    $cv->begin(sub { $cv->send });
-    $cv->begin;
-    # ping
-    $riak->is_alive(
-        callback => sub {
-            my $res = shift;
-            pass "is alive in cb" if $res;
-            $cv->end;
-        }
-    );
-    $cv->end;
-    $cv->recv;
-}
-
-{
-    my $cv = AnyEvent->condvar;
-    $cv->begin(sub { $cv->send });
-    $cv->begin;
-    # list bucket
-    $riak->list_bucket(
-        $bucket,
-        parameters => {props => 'true', keys => 'true'},
-        callback   => sub {
-            my $res = shift;
-            ok $res->{props}, 'got props';
-            $cv->end;
-        }
-    );
-    $cv->end;
-    $cv->recv;
-}
-
-{
-    my $value = {foo => 'bar',};
-    my $cv = AnyEvent->condvar;
-    $cv->begin(sub { $cv->send });
-    $cv->begin;
-
-    # store object
-    $riak->store(
-        $bucket, 'bar3', $value,
-        callback => sub {
-            pass "store value ok";
-            $riak->fetch(
-                'foo', 'bar3',
-                callback => sub {
-                    my $body = shift;
-                    is_deeply($body, $value, 'value is ok in cb');
-                    $cv->end;
-                }
-            );
-        }
-    );
-    $cv->end;
-    $cv->recv;
-}