view release on metacpan or  search on metacpan

lib/AnyMQ/Trait/ZeroMQ.pm  view on Meta::CPAN

117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
 
    $self->update_topic_subscriptions;
 
    # for now just use $cb as ref, should generate some unique
    # id in the future
    my $ref = $cb;
    return $ref;
}
 
# this controls what events we are subscribed to in ZMQ
sub update_topic_subscriptions {
    my ($self) = @_;
 
    my @topics = $self->subscription_topics;
     
    # update list of topics we are subscribed to
    # FIXME: use trait::topics
    # $self->_zmq_sub->topics(\@topics);
}
 
sub unsubscribe {