File Coverage

blib/lib/Sys/Async/Virt/Callback.pm

Criterion	Covered	Total	%
statement	29	68	42.6
branch	0	8	0.0
condition			n/a
subroutine	10	17	58.8
pod	2	5	40.0
total	41	98	41.8

####################################################################
#
#     This file was generated using XDR::Parse version v1.0.1
#                   and LibVirt version v12.1.0
#
#      Don't edit this file, use the source template instead
#
#                 ANY CHANGES HERE WILL BE LOST !
#
####################################################################


use v5.26;
use warnings;
use experimental qw/ signatures /;
use Feature::Compat::Try;
use Future::AsyncAwait;
use Object::Pad 0.821;

class Sys::Async::Virt::Callback v0.6.1;


use Carp qw(croak);
use Future::Queue;
use Log::Any qw($log);

use Protocol::Sys::Virt::Remote::XDR v12.1.0;
my $remote = 'Protocol::Sys::Virt::Remote::XDR';

field $_rpc_id          :reader :param;
field $_client          :reader :param;
field $_deregister_call :param;
field $_queue;
field $_cancelled;

ADJUST :params (:$queue_len //= 12, :$factory) {
    $_queue = Future::Queue->new(
        max_items => $queue_len,
        prototype => $factory
        );
}

async method next_event() {
    return unless $_queue; # simulate an empty queue
    return await $_queue->shift;
}

async method cancel() {
    return await $_cancelled if $_cancelled;

    $_cancelled = $_client->loop->new_future;
    $self->cleanup;
    await $_cancelled;

    return;
}

method cleanup() {
    return unless $_queue;

    $_queue->finish;
    $_queue = undef;
    $_client->_deregister_callback(
        $_cancelled,
        $_deregister_call,
        $_rpc_id );

    return;
}

method _dispatch_event($event) {
    return if $_cancelled;

    try {
        $_queue->push($event);
    }
    catch ($e) {
        $self->cleanup;
    }
}

method DESTROY() {
    $self->cleanup;
}


1;

__END__