Google-ProtocolBuffers-Dynamic

 view release on metacpan or  search on metacpan

t/605_basic_grpc.t  view on Meta::CPAN

use t::lib::GrpcClient;

spawn_server('t/grpc/sayhello.pl');

my $d = Google::ProtocolBuffers::Dynamic->new('t/proto');
$d->load_file("grpc/greeter.proto");
$d->map(
    { package => 'helloworld', prefix => 'Helloworld', options => { client_services => 'grpc_xs' } },
);

my $credentials = Grpc::XS::ChannelCredentials::createInsecure;
my $greeter = Helloworld::Greeter->new(
    server_address,
    credentials => $credentials,
);
my $request = Helloworld::HelloRequest->new({
    name => 'grpc-perl',
});
my $call = $greeter->SayHello( argument => $request );
my $response = $call->wait;

ok($response, 'got a response');
is($response && $response->get_message, 'Hello, grpc-perl');

t/610_stream_client_grpc.t  view on Meta::CPAN

use t::lib::GrpcClient;

spawn_server('t/grpc/sayhello_stream_client.pl');

my $d = Google::ProtocolBuffers::Dynamic->new('t/proto');
$d->load_file("grpc/greeter.proto");
$d->map(
    { package => 'helloworld', prefix => 'Helloworld', options => { client_services => 'grpc_xs' } },
);

my $credentials = Grpc::XS::ChannelCredentials::createInsecure;
my $greeter = Helloworld::Greeter->new(
    server_address,
    credentials => $credentials,
);
my $call = $greeter->JoinedHello();
for my $char (split //, 'grpc-perl') {
    $call->write(Helloworld::HelloRequest->new({
        name => $char,
    }));
}
my $response = $call->wait;

ok($response, 'got a response');

t/615_stream_server_grpc.t  view on Meta::CPAN

use t::lib::GrpcClient;

spawn_server('t/grpc/sayhello_stream_server.pl');

my $d = Google::ProtocolBuffers::Dynamic->new('t/proto');
$d->load_file("grpc/greeter.proto");
$d->map(
    { package => 'helloworld', prefix => 'Helloworld', options => { client_services => 'grpc_xs' } },
);

my $credentials = Grpc::XS::ChannelCredentials::createInsecure;
my $greeter = Helloworld::Greeter->new(
    server_address,
    credentials => $credentials,
);
my $request = Helloworld::HelloRequest->new({
    name => 'grpc-perl',
});
my $call = $greeter->SplitHello( argument => $request );
my @responses = $call->responses;

is(scalar @responses, 10);
is(join('', map $_->get_message, @responses), 'Hello, grpc-perl');

t/620_stream_bidi_grpc.t  view on Meta::CPAN

use t::lib::GrpcClient;

spawn_server('t/grpc/sayhello_stream_bidi.pl');

my $d = Google::ProtocolBuffers::Dynamic->new('t/proto');
$d->load_file("grpc/greeter.proto");
$d->map(
    { package => 'helloworld', prefix => 'Helloworld', options => { client_services => 'grpc_xs' } },
);

my $credentials = Grpc::XS::ChannelCredentials::createInsecure;
my $greeter = Helloworld::Greeter->new(
    server_address,
    credentials => $credentials,
);
my $call = $greeter->WavingHello();
my @chars = split //, 'grpc-perl';
my @responses;

for (;;) {
    my $response = $call->read;
    push @responses, $response if $response;
    last if !$response && !@chars;
    if (@chars) {