Skip to content

Commit

Permalink
Subscribe for current interest
Browse files Browse the repository at this point in the history
  • Loading branch information
sashacmc committed Jan 28, 2025
1 parent 8f6487e commit 5bac814
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/net/matching.c
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@
#include "zenoh-pico/api/types.h"
#include "zenoh-pico/net/primitives.h"
#include "zenoh-pico/net/session.h"
#include "zenoh-pico/protocol/definitions/interest.h"
#include "zenoh-pico/session/matching.h"
#include "zenoh-pico/session/resource.h"
#include "zenoh-pico/utils/logging.h"
Expand Down Expand Up @@ -55,8 +56,8 @@ static void _z_matching_listener_callback(const _z_interest_msg_t *msg, void *ar

_z_matching_listener_t _z_matching_listener_declare(_z_session_rc_t *zn, const _z_keyexpr_t *key, _z_zint_t entity_id,
uint8_t interest_type_flag, _z_closure_matching_status_t callback) {
uint8_t flags =
interest_type_flag | _Z_INTEREST_FLAG_RESTRICTED | _Z_INTEREST_FLAG_FUTURE | _Z_INTEREST_FLAG_AGGREGATE;
uint8_t flags = interest_type_flag | _Z_INTEREST_FLAG_RESTRICTED | _Z_INTEREST_FLAG_FUTURE |
_Z_INTEREST_FLAG_AGGREGATE | _Z_INTEREST_FLAG_CURRENT;
_z_matching_listener_t ret = _z_matching_listener_null();

_z_matching_listener_ctx_t *ctx = _z_matching_listener_ctx_new(callback);
Expand Down

0 comments on commit 5bac814

Please sign in to comment.