Simplified default callbacks that emit events. Added stubs for other …

…necessary roles.

eg/roles/Alarm.pm

@@ -0,0 +1 @@
+# TODO - An absolute time alarm that can be snoozed, etc.

eg/roles/Connects.pm

@@ -0,0 +1 @@
+# TODO - Makes a connection.

eg/roles/Datagrams.pm

@@ -0,0 +1 @@
+# TODO - Interacts with datagram sockets.

eg/roles/EmitHelper.pm

@@ -0,0 +1,24 @@
+package EmitHelper;
+
+use warnings;
+use strict;
+
+use Exporter;
+use base 'Exporter';
+
+our @EXPORT_OK = qw(default_emit);
+
+# Helper function.  Returns a role method that emits an event.  Used
+# as the default callback for many things.
+
+sub default_emit {
+	my ($cb_name, $event) = @_;
+	return(
+		$cb_name => sub {
+			my ($self, $args) = @_;
+			$self->emit(event => $event, args => $args);
+		}
+	);
+}
+
+1;

eg/roles/Listens.pm

@@ -0,0 +1 @@
+# TODO - Listens for new connections.

eg/roles/ReapsPids.pm

@@ -0,0 +1 @@
+# TODO - Handle SIGCHLD

eg/roles/Signal.pm

@@ -0,0 +1,32 @@
+package Signal;
+use MoseX::Role::Parameterized;
+
+parameter signal => (
+	isa => 'Str',
+	required  => 1,
+);
+
+parameter cb_signal => (
+	isa       => 'Str',
+	default   => sub {
+		my $self = shift;
+		"on_" . lc($self->signal()) . "_caught";
+	},
+	lazy      => 1,
+);
+
+role {
+	after BUILD => sub {
+		# ... register the handler
+	};
+
+	method stop => sub {
+		# ... deregister the signal handler
+	};
+
+	after DEMOLISH => sub {
+		# ... make sure the signal is not watched anymore
+	};
+};
+
+1;

eg/roles/Signalable.pm

@@ -0,0 +1 @@
+# TODO - Handle signals, generically.

eg/roles/Stream.pm

@@ -4,32 +4,12 @@ extends 'Reflex::Object';
 
 has handle => ( is => 'rw', isa => 'FileHandle', required => 1 );
 
-with 'Streamable' => { handle => 'handle' };
+with 'Streamable' => {
+	handle => 'handle',
 
-# TODO - Would be nice to alias put_handle() to put().
-sub put {
-	my $self = shift;
-	$self->put_handle(@_);
-}
-
-# Default callback emits an event.
-# TODO - Common convention.  How to make this generic?
-sub on_handle_data {
-	my ($self, $args) = @_;
-	$self->emit(
-		event => "data",
-		args => $args
-	);
-}
-
-# Default callback emits an event.
-# TODO - Common convention.  How to make this generic?
-sub on_handle_error {
-	my ($self, $args) = @_;
-	$self->emit(
-		event => "data",
-		args => $args
-	);
-}
+	# Expose put_handle() as put().
+	-alias => { put_handle => 'put' },
+	-excludes => 'put_handle',
+};
 
 1;

eg/roles/Streamable.pm

@@ -1,5 +1,6 @@
 package Streamable;
 use MooseX::Role::Parameterized;
+use EmitHelper qw(default_emit);
 
 use Scalar::Util qw(weaken);
 
@@ -93,8 +94,6 @@ role {
 						errfun => "syswrite",
 					}
 				);
-
-				$self->_emit_failure("syswrite");
 				return;
 			}
 
@@ -115,6 +114,10 @@ role {
 		# Flushed it all.  Yay!
 		return 0;
 	};
+
+	# Default callbacks that re-emit their parameters.
+	method default_emit($cb_data,  "data");
+	method default_emit($cb_error, "error");
 };
 
 1;

eg/roles/Ticker.pm

@@ -0,0 +1 @@
+# TODO - A periodic timer that throws repeating events.

eg/roles/Timeout.pm

@@ -0,0 +1 @@
+# TODO - A delay-like timeout that can be reset.