package Gearman::ResponseParser::Taskset;

use strict;
use base 'Gearman::ResponseParser';
use Gearman::Taskset;

sub new {
    my ($class, %opts) = @_;
    my $ts = delete $opts{taskset};
    my $self = $class->SUPER::new(%opts);
    $self->{_taskset} = $ts;
    return $self;
}

sub on_packet {
    my ($self, $packet, $parser) = @_;
    $self->{_taskset}->_process_packet($packet, $parser->source);
}

sub on_error {
    my ($self, $errmsg) = @_;
    die "ERROR: $errmsg\n";
}

1;