poe_win32_stdin.pl

use strict;
use warnings;
use threads;
use Thread::Queue;
use POE;

$|=1;

my $queue = Thread::Queue->new;
async { $queue->enqueue( $_ ) while defined( $_ = <STDIN> ); }->detach;

POE::Session->create(
  package_states => [
    main => [qw(_start _check)],
  ],
);

$poe_kernel->run();
exit 0;

sub _start {
  my ($kernel,$heap) = @_[KERNEL,HEAP];
  $kernel->yield( '_check' );
  return;
}

sub _check {
  my ($kernel,$heap) = @_[KERNEL,HEAP];
  while ( $queue->pending ) {
    my $input = $queue->dequeue;
    print $input;
  }
  $kernel->yield( '_check' ) if scalar threads->list();
  return;
}