[ViewVC] Diff of: cvs/AnyEvent-MP/MP.pm

Comparing AnyEvent-MP/MP.pm (file contents):
Revision 1.12 by root, Sun Aug 2 18:11:48 2009 UTC vs.
Revision 1.16 by root, Sun Aug 2 19:29:41 2009 UTC

 Create a new local port object. See the next section for allowed methods.
 =cut
 sub create_port {
-   my $id = "$AnyEvent::MP::Base::UNIQ." . ++$AnyEvent::MP::Base::ID;
+   my $id = "$AnyEvent::MP::Base::UNIQ." . $AnyEvent::MP::Base::ID++;
    my $self = bless {
       id    => "$NODE#$id",
       names => [$id],
    }, "AnyEvent::MP::Port";
    };
    $self
 }
-=item $portid = create_miniport { }
+=item $portid = miniport { my @msg = @_; $finished }
-Creates a "mini port", that is, a port without much #TODO
+Creates a "mini port", that is, a very lightweight port without any
+pattern matching behind it, and returns its ID.
-=cut
+The block will be called for every message received on the port. When the
+callback returns a true value its job is considered "done" and the port
+will be destroyed. Otherwise it will stay alive.
+The message will be passed as-is, no extra argument (ie.. no port id) will
+be passed to the callback.
+If you need the local port id in the callback, this works nicely:
+   my $port; $port = miniport {
+      snd $otherport, reply => $port;
+   };
+=cut
-sub create_miniport(&) {
+sub miniport(&) {
    my $cb = shift;
-   my $id = "$AnyEvent::MP::Base::UNIQ." . ++$AnyEvent::MP::Base::ID;
+   my $id = "$AnyEvent::MP::Base::UNIQ." . $AnyEvent::MP::Base::ID++;
    $AnyEvent::MP::Base::PORT{$id} = sub {
-      $_[0] = "$NODE#$id";
       &$cb
          and delete $AnyEvent::MP::Base::PORT{$id};
    };
    "$NODE#$id"

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines