Y::Notifier - Implementation - Client API

---

• The Client API is as simple as possible
• my $handle = new Y::Notifier($host, $port);
• $host and $port are optional
• $handle->Register($subject, $sub);
• $sub takes the recieved message $subject and $body as argument
• $handle->RegisterTimer($ms, $sub);
• $sub takes no arguments, $ms is milliseconds
• $handle->RegisterFileHandle($fh, $sub);
• $sub takes the line read as argument
• $handle->RegisterErrorHandler($sub);
• $sub takes no arguments
• $handle->Send($subject, $rh_body);
• $handle->Forget($subject);
• $handle->Listen($timeout);
• $handle->Flush();
• Optionally, instead of a subroutine reference, each of the Register* methods will accept an object and a method name to invoke on that object
• Send, by virtue of a local (not my) variable, is aware of whether it is being called from inside an event loop (as set up by Listen)
• If within an event loop, the message is queued for later delivery as the socket connections become available for write (non-blocking)
• If outside of an event loop the message is flushed in blocking mode

---

Y::Notifier - Implementation - Client API