| … | |
… | |
| 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 | }; |
