summaryrefslogtreecommitdiff
path: root/t/10_async.t
diff options
context:
space:
mode:
Diffstat (limited to '')
-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;
-}