new Client/Router/Service arch

[scpubgit/Tak.git] / lib / Tak / Request.pm

package Tak::Request;

use Tak::Result;
use Moo;

has on_progress => (is => 'ro');

has on_result => (is => 'ro', required => 1);

sub progress {
  my ($self, @report) = @_;
  if (my $cb = $self->on_progress) {
    $cb->(@report);
  }
}

sub result {
  my ($self, $type, @data) = @_;
  $self->on_result->(Tak::Result->new(type => $type, data => \@data));
}

sub success { shift->result(success => @_) }
sub mistake { shift->result(mistake => @_) }
sub failure { shift->result(failure => @_) }
sub fatal { shift->result(fatal => @_) }

1;