Mojo TCP server which emits signal for each line

tcp_server_on_line.pl

use v5.14;

use Mojo::IOLoop;

use Data::Dump;

my %opts = (address => '0.0.0.0', port => 1514, map { split /=/, $_, 2 } @ARGV);

Mojo::IOLoop->server(%opts, sub {
    my ($loop, $stream, $id) = @_;

    my $leftovers = '';

    $stream->on(read => sub {
        my ($stream, $buf) = @_;
        if ($leftovers ne '') {
            $buf = $leftovers . $buf;
            $leftovers = '';
        }
        while ($buf =~ s/(.*?)(\x0d?\x0a)//) {
            $stream->emit(line => "$1$2");
        }
        $leftovers = $buf;
    });
    $stream->on(close => sub {
        my ($stream, $buf) = @_;
        if ($leftovers ne '') {
            $stream->emit(line => $leftovers);
        }
    });

    $stream->on(line => sub {
        my ($stream, $line) = @_;
        ddx $line;
    });

});

# Start event loop
Mojo::IOLoop->start;