NAME

Zing::Mailbox - Process Mailbox

ABSTRACT

Interprocess Communication Mechanism

SYNOPSIS

use Zing::Mailbox;

my $mailbox = Zing::Mailbox->new(name => rand);

# $mailbox->recv;

DESCRIPTION

This package provides represents a process mailbox, the default mechanism of interprocess communication.

INHERITS

This package inherits behaviors from:

Zing::PubSub

LIBRARIES

This package uses type constraints from:

Zing::Types

ATTRIBUTES

This package has the following attributes:

name

name(Str)

This attribute is read-only, accepts (Str) values, and is optional.

METHODS

This package implements the following methods:

recv

recv() : Maybe[HashRef]

The recv method receives a single new message from the mailbox.

recv example #1

# given: synopsis

$mailbox->recv;

recv example #2

# given: synopsis

$mailbox->send($mailbox->term, { status => 'hello' });

$mailbox->recv;

reply

reply(HashRef $message, HashRef $value) : Int

The reply method sends a message to the mailbox represented by the $bag received and returns the size of the recipient mailbox.

reply example #1

# given: synopsis

$mailbox->send($mailbox->term, { status => 'hello' });

my $message = $mailbox->recv;

$mailbox->reply($message, { status => 'thank you' });

send

send(Str $key, HashRef $value) : Int

The send method sends a new message to the mailbox specified and returns the size of the recipient mailbox.

send example #1

# given: synopsis

$mailbox->send($mailbox->term, { status => 'hello' });

size

size() : Int

The size method returns the message count of the mailbox.

size example #1

# given: synopsis

my $size = $mailbox->size;

AUTHOR

Al Newkirk, awncorp@cpan.org

LICENSE

This is free software; you can redistribute it and/or modify it under the terms of the The Apache License, Version 2.0, as elucidated in the "license file".