WebService-Amazon-DynamoDB-Server

 view release on metacpan or  search on metacpan

bin/dynamodb-tan-client  view on Meta::CPAN

use Log::Any::Adapter 'Stdout';

sub status($) { warn "@_\n" }

my $loop = IO::Async::Loop->new;
$loop->add(
	my $client = Net::Async::Tangence::Client->new(
	)
);

sub subscribe_event(&@) {
	my ($code, $obj, $ev) = @_;
	my $f = $loop->new_future;
	$obj->subscribe_event(
		event         => $ev,
		on_fire       => $code,
		on_subscribed => sub { $f->done($obj) },
		on_fail       => $f->curry::fail
	);
	$f->on_ready(sub { undef $f });
}

bin/dynamodb-tickit-client  view on Meta::CPAN

=item * $code - callback to run on event trigger

=item * $obj - L<Tangence::ObjectProxy> to watch

=item * $ev - which event

=back

=cut

sub subscribe_event(&@) {
	my ($code, $obj, $ev) = @_;
	my $f = loop->new_future;
	$obj->subscribe_event(
		event         => $ev,
		on_fire       => $code,
		on_subscribed => sub { $f->done($obj) },
		on_fail       => $f->curry::fail
	);
	$f->on_ready(sub { undef $f });
}

lib/Test/WebService/Amazon/DynamoDB/Server.pm  view on Meta::CPAN

	);
}

use WebService::Amazon::DynamoDB::Server;

use Test::More;
use Future::Utils qw(fmap repeat call);

our $SRV;

sub fmap_over(&;@) {
	my ($code, %args) = @_;
	my @result;
	(repeat {
		(shift || Future->done)->then(sub {
			my $last = shift;
			call {
				$code->($last)->on_done(sub {
					push @result, @_
				})
			}

lib/Test/WebService/Amazon/DynamoDB/Server.pm  view on Meta::CPAN

   get_item => 4,
   describe_table => 1
  }
 };
 ...

Returns that instance when done.

=cut

sub ddb_server(&;@) {
	my ($code) = shift;
	local $SRV = new_ok('WebService::Amazon::DynamoDB::Server');
	$code->($SRV);
	$SRV
}

=head2 add_table

Adds the given table spec.