… | |
… | |
125 | Create a new local port object. See the next section for allowed methods. |
125 | Create a new local port object. See the next section for allowed methods. |
126 | |
126 | |
127 | =cut |
127 | =cut |
128 | |
128 | |
129 | sub create_port { |
129 | sub create_port { |
130 | my $id = "$AnyEvent::MP::Base::UNIQ." . ++$AnyEvent::MP::Base::ID; |
130 | my $id = "$AnyEvent::MP::Base::UNIQ." . $AnyEvent::MP::Base::ID++; |
131 | |
131 | |
132 | my $self = bless { |
132 | my $self = bless { |
133 | id => "$NODE#$id", |
133 | id => "$NODE#$id", |
134 | names => [$id], |
134 | names => [$id], |
135 | }, "AnyEvent::MP::Port"; |
135 | }, "AnyEvent::MP::Port"; |
… | |
… | |
178 | |
178 | |
179 | =cut |
179 | =cut |
180 | |
180 | |
181 | sub miniport(&) { |
181 | sub miniport(&) { |
182 | my $cb = shift; |
182 | my $cb = shift; |
183 | my $id = "$AnyEvent::MP::Base::UNIQ." . ++$AnyEvent::MP::Base::ID; |
183 | my $id = "$AnyEvent::MP::Base::UNIQ." . $AnyEvent::MP::Base::ID++; |
184 | |
184 | |
185 | $AnyEvent::MP::Base::PORT{$id} = sub { |
185 | $AnyEvent::MP::Base::PORT{$id} = sub { |
186 | &$cb |
186 | &$cb |
187 | and delete $AnyEvent::MP::Base::PORT{$id}; |
187 | and delete $AnyEvent::MP::Base::PORT{$id}; |
188 | }; |
188 | }; |