perl/lib/Net/REPL/Client/Queue.pm

   1 package Net::REPL::Client::Queue;
   2 use strict;
   3 use warnings;
   4
   5 use base qw(Net::REPL::Client);
   6
   7 sub new {
   8     my $proto = shift;
   9     my $class = ref($proto) || $proto;
  10     my $self = $class->SUPER::new(
  11         'input_queue' => [],
  12         'output_queue' => [],
  13         @_,
  14     );
  15     return $self;
  16 }
  17
  18 sub queue_input {
  19     my ($self, $input) = @_;
  20     push(@{$self->{'input_queue'}}, $input);
  21 }
  22
  23 sub setup_io {
  24     my ($self) = @_;
  25
  26     $self->{'out_fh'} = \*STDOUT;
  27 }
  28
  29 sub read {
  30     my ($self) = @_;
  31     return shift(@{$self->{'input_queue'}})
  32 }
  33
  34 sub print {
  35     my ($self, @output) = @_;
  36
  37     push(@{$self->{'output_queue'}}, @output);
  38 }
  39
  40 1;