#!/usr/bin/env perl
use warnings;
use strict;
use Mojo::Util qw/dumper/;
use Mojo::IOLoop;
use Mojo::IOLoop::Stream::Role::LineBuffer;

Mojo::IOLoop->client(
	{ address => '127.0.0.1', port => 3000 } => sub {
		my ($loop, $err, $stream) = @_;
		if (defined $err) { warn "Error: $err"; return }
		print "Connect\n";
		$stream->timeout(10);
		$stream = $stream->with_roles('+LineBuffer')->watch_lines;
		$stream->on(read_line => sub {
			my ($strm, $line, $sep) = @_;
			print "Got line ".dumper($line);
		});
		$stream->on(timeout => sub { print "Timeout\n" });
		$stream->on(close => sub { print "Closed\n" });
		$stream->on(error => sub { warn "Error: $_[1]" });
		$stream->write("Hello, server, I am a client.\n");
	});
print "Starting client...\n";
Mojo::IOLoop->start unless Mojo::IOLoop->is_running;