#!/usr/bin/perl

use Mojolicious::Lite;
use Mojolicious::Plugin::ForkCoupled;

app->plugin('Mojolicious::Plugin::ForkCoupled');

get '/forktest' => sub {
    my $c = shift;
    my $child = app->fork_coupled(
            'cmd' => ['/tmp/coupledforktestchild.pl', 'arg1', 'arg2'],
            );
    $c->write;
    $child->on('read_stdout' => sub {
            my $child  = shift;
            my $stream = shift;
            my $data   = shift;
            foreach my $line (split /^/, $data) {
                    $c->write($line) if $c->tx;
                    $child->write_stdin(time."\n") if $line =~ /^feed me/;
            }
    });
    $child->on('finish_stdout' => sub {
            $c->finish;
            undef $child;
    });
};

app->start;

#!/usr/bin/perl

$| = 1;
print "first $ARGV[0]\n";
sleep 2;
print "second $ARGV[1]\n";
sleep 1;
print "feed me please\n";
my $input1 = <STDIN>;
chomp $input1;
sleep 2;
print "third $input1\n";
print "feed me again\n";
my $input2 = <STDIN>;
chomp $input2;
sleep 1;
print "final $input1 $input2\n";
sleep 1;
print "byebye\n";

my $child1 = Mojolicious::Plugin::ForkCoupled->fork_exec(
    'cmd'     => '/path/to/executable',
    'ctrlr'   => $c,
    );

my $child2 = Mojolicious::Plugin::ForkCoupled->fork_exec(
    'cmd'     => ['/path/to/executable', 'arg1', 'arg2'],
    'ctrlr'   => $c,
    );

$child->write_stdin("child_command info data stuff\n");