Mojo-IOLoop-Tail.pm

package Mojo::IOLoop::Tail;
use Mojo::Base "Mojo::IOLoop::Stream";

has check_timeout => 0.01;

sub close {
  my $self = shift;

  return unless my $handle  = $self->{handle};
  seek $handle, 0, 1;
  $self->stop;
}

sub new {
  my ($class, $fh) = @_;
  my ($self, $tid);

  unless (ref $fh) {
    open my $FH, "<", $fh or die "Open $fh: $!";
    $fh = $FH;
  }

  seek $fh, 0, 2; # seek to end of file
  $self = $class->SUPER::new($fh);
  $self->{tail_tid} = $self->reactor->recurring($self->check_timeout, sub { $self and $self->start });
  $self;
}

sub DESTROY {
  my $self = shift;
  my $reactor = $self->reactor;
  $self->SUPER::close;
  $reactor->remove($self->{tail_tid}) if $reactor;
}