| /dports/www/p5-Mojolicious/Mojolicious-9.22/t/mojo/ |
| H A D | eventemitter.t | 29 ok !$e->has_subscribers('foo'), 'no subscribers';
31 ok $e->has_subscribers('error'), 'has subscribers';
84 $e->once(one_time => sub { $once = shift->has_subscribers('one_time') });
120 ok !$e->has_subscribers('foo'), 'no subscribers';
123 ok $e->has_subscribers('foo'), 'has subscribers';
126 ok !$e->has_subscribers('foo'), 'no subscribers';
142 ok $e->has_subscribers('foo'), 'has subscribers';
143 ok !$e->unsubscribe('foo')->has_subscribers('foo'), 'no subscribers';
|
| H A D | reactor_ev.t | 263 ok $reactor->has_subscribers('error'), 'has subscribers';
265 ok !$reactor->has_subscribers('error'), 'no subscribers';
|
| H A D | reactor_poll.t | 261 ok $reactor->has_subscribers('error'), 'has subscribers';
263 ok !$reactor->has_subscribers('error'), 'no subscribers';
|
| H A D | ioloop.t | 159 ok !!Mojo::IOLoop->singleton->has_subscribers('finish'), 'has subscribers';
161 ok !Mojo::IOLoop->singleton->has_subscribers('finish'), 'no subscribers';
|
| H A D | user_agent.t | 599 ok !$ua->has_subscribers('start'), 'unsubscribed successfully';
|
| /dports/net/p5-POE-Component-PubSub/POE-Component-PubSub-0.091370/lib/POE/Component/ |
| H A D | PubSub.pm | 79 if(!$event->has_subscribers)
167 if($event->has_subscribers)
252 if($event->has_subscribers)
|
| /dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/Transaction/ |
| H A D | WebSocket.pm | 101 $self->emit(json => j($msg)) if $self->has_subscribers('json');
104 …$self->emit(message => $op == WS_TEXT ? decode 'UTF-8', $msg : $msg) if $self->has_subscribers('me…
|
| /dports/net/p5-POE-Component-PubSub/POE-Component-PubSub-0.091370/lib/POE/Component/PubSub/ |
| H A D | Event.pm | 38 has_subscribers => 'size',
|
| /dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/ |
| H A D | EventEmitter.pm | 25 sub has_subscribers { !!shift->{events}{shift()} } subroutine
|
| /dports/www/p5-Mojo-Weixin/Mojo-Weixin-1.4.6/lib/Mojo/Weixin/Message/Remote/ |
| H A D | _upload_media.pm | 151 }) if !$msg->has_subscribers('_upload_media_chunk_over');
154 }) if !$msg->has_subscribers('_upload_media_chunk');;
|
| /dports/devel/py-pyro/Pyro4-4.77/examples/messagebus/messagebus/ |
| H A D | messagebus.py | 174 def has_subscribers(self, topic): member in MemoryStorage
346 def has_subscribers(self, topic): member in SqliteStorage
423 if self.storage.has_pending_messages(topic) or self.storage.has_subscribers(topic):
|
| /dports/www/p5-Mojolicious/Mojolicious-9.22/lib/Mojo/IOLoop/ |
| H A D | Stream.pm | 43 return !!length($self->{buffer}) || $self->has_subscribers('drain');
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/dashboard/dashboard/ |
| H A D | add_histograms_queue.py | 261 has_subscribers = utils.IsMonitored(client, test.test_path)
262 if not has_subscribers:
|
| /dports/deskutils/gnome-calendar/gnome-calendar-41.2/src/core/ |
| H A D | gcal-timeline.c | 236 gboolean has_subscribers; in update_range() local
242 has_subscribers = g_hash_table_size (self->subscribers) > 0; in update_range()
244 if (has_subscribers) in update_range()
|
| /dports/sysutils/watchman/watchman-4.5.0/ |
| H A D | root.c | 1643 bool has_subscribers = false; in root_has_subscriptions() local
1655 has_subscribers = true; in root_has_subscriptions()
1660 } while (!has_subscribers && w_ht_next(clients, &iter)); in root_has_subscriptions()
1662 return has_subscribers; in root_has_subscriptions()
|