Remove const from closure params

examples/arduino/z_get.ino

@@ -38,7 +38,7 @@ void reply_dropper(void *ctx) {
     Serial.println(" >> Received query final notification");
 }
 
-void reply_handler(const z_loaned_reply_t *oreply, void *ctx) {
+void reply_handler(z_loaned_reply_t *oreply, void *ctx) {
     (void)(ctx);
     if (z_reply_is_ok(oreply)) {
         const z_loaned_sample_t *sample = z_reply_ok(oreply);

examples/arduino/z_queryable.ino

@@ -34,7 +34,7 @@
 z_owned_session_t s;
 z_owned_queryable_t qable;
 
-void query_handler(const z_loaned_query_t *query, void *arg) {
+void query_handler(z_loaned_query_t *query, void *arg) {
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);
     Serial.print(" >> [Queryable handler] Received Query '");

examples/arduino/z_scout.ino

@@ -75,7 +75,7 @@ void fprinthello(const z_loaned_hello_t *hello) {
     Serial.println(" }");
 }
 
-void callback(const z_loaned_hello_t *hello, void *context) {
+void callback(z_loaned_hello_t *hello, void *context) {
     fprinthello(hello);
     Serial.println("");
     (*(int *)context)++;

examples/arduino/z_sub.ino

@@ -33,7 +33,7 @@
 z_owned_session_t s;
 z_owned_subscriber_t sub;
 
-void data_handler(const z_loaned_sample_t *sample, void *arg) {
+void data_handler(z_loaned_sample_t *sample, void *arg) {
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);
     z_owned_string_t value;

examples/espidf/z_get.c

@@ -103,7 +103,7 @@ void wifi_init_sta(void) {
 
 void reply_dropper(void *ctx) { printf(" >> Received query final notification\n"); }
 
-void reply_handler(const z_loaned_reply_t *oreply, void *ctx) {
+void reply_handler(z_loaned_reply_t *oreply, void *ctx) {
     if (z_reply_is_ok(oreply)) {
         const z_loaned_sample_t *sample = z_reply_ok(oreply);
         z_view_string_t keystr;

examples/espidf/z_queryable.c

@@ -101,7 +101,7 @@ void wifi_init_sta(void) {
     vEventGroupDelete(s_event_group_handler);
 }
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);

examples/espidf/z_scout.c

@@ -129,7 +129,7 @@ void fprinthello(FILE *stream, const z_loaned_hello_t *hello) {
     fprintf(stream, " }");
 }
 
-void callback(const z_loaned_hello_t *hello, void *context) {
+void callback(z_loaned_hello_t *hello, void *context) {
     fprinthello(stdout, hello);
     fprintf(stdout, "\n");
     (*(int *)context)++;

examples/espidf/z_sub.c

@@ -100,7 +100,7 @@ void wifi_init_sta(void) {
     vEventGroupDelete(s_event_group_handler);
 }
 
-void data_handler(const z_loaned_sample_t* sample, void* arg) {
+void data_handler(z_loaned_sample_t* sample, void* arg) {
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);
     z_owned_string_t value;

examples/freertos_plus_tcp/z_get.c

@@ -36,7 +36,7 @@ void reply_dropper(void *ctx) {
     printf(">> Received query final notification\n");
 }
 
-void reply_handler(const z_loaned_reply_t *reply, void *ctx) {
+void reply_handler(z_loaned_reply_t *reply, void *ctx) {
     (void)(ctx);
     if (z_reply_is_ok(reply)) {
         const z_loaned_sample_t *sample = z_reply_ok(reply);

examples/freertos_plus_tcp/z_queryable.c

@@ -29,7 +29,7 @@
 #define KEYEXPR "demo/example/zenoh-pico-queryable"
 #define VALUE "[FreeRTOS-Plus-TCP] Queryable from Zenoh-Pico!"
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);

examples/freertos_plus_tcp/z_scout.c

@@ -63,7 +63,7 @@ void fprinthello(FILE *stream, const z_loaned_hello_t *hello) {
     fprintf(stream, " }");
 }
 
-void callback(const z_loaned_hello_t *hello, void *context) {
+void callback(z_loaned_hello_t *hello, void *context) {
     fprinthello(stdout, hello);
     fprintf(stdout, "\n");
     (*(int *)context)++;

examples/freertos_plus_tcp/z_sub.c

@@ -28,7 +28,7 @@
 
 #define KEYEXPR "demo/example/**"
 
-void data_handler(const z_loaned_sample_t *sample, void *ctx) {
+void data_handler(z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/freertos_plus_tcp/z_sub_st.c

@@ -31,7 +31,7 @@
 
 int msg_nb = 0;
 
-void data_handler(const z_loaned_sample_t *sample, void *ctx) {
+void data_handler(z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/mbed/z_get.cpp

@@ -33,7 +33,7 @@
 
 void reply_dropper(void *ctx) { printf(" >> Received query final notification\n"); }
 
-void reply_handler(const z_loaned_reply_t *oreply, void *ctx) {
+void reply_handler(z_loaned_reply_t *oreply, void *ctx) {
     if (z_reply_is_ok(oreply)) {
         const z_loaned_sample_t *sample = z_reply_ok(oreply);
         z_view_string_t keystr;

examples/mbed/z_queryable.cpp

@@ -31,7 +31,7 @@
 #define KEYEXPR "demo/example/zenoh-pico-queryable"
 #define VALUE "[MBedOS]{nucleo-F767ZI} Queryable from Zenoh-Pico!"
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);

examples/mbed/z_scout.cpp

@@ -71,7 +71,7 @@ void fprinthello(FILE *stream, const z_loaned_hello_t *hello) {
     fprintf(stream, " }");
 }
 
-void callback(const z_loaned_hello_t *hello, void *context) {
+void callback(z_loaned_hello_t *hello, void *context) {
     fprinthello(stdout, hello);
     fprintf(stdout, "\n");
     (*(int *)context)++;

examples/mbed/z_sub.cpp

@@ -30,7 +30,7 @@
 
 #define KEYEXPR "demo/example/**"
 
-void data_handler(const z_loaned_sample_t *sample, void *arg) {
+void data_handler(z_loaned_sample_t *sample, void *arg) {
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);
     z_owned_string_t value;

examples/unix/c11/z_get.c

@@ -31,7 +31,7 @@ void reply_dropper(void *ctx) {
     z_drop(z_move(cond));
 }
 
-void reply_handler(const z_loaned_reply_t *reply, void *ctx) {
+void reply_handler(z_loaned_reply_t *reply, void *ctx) {
     (void)(ctx);
     if (z_reply_is_ok(reply)) {
         const z_loaned_sample_t *sample = z_reply_ok(reply);

examples/unix/c11/z_get_attachment.c

@@ -99,7 +99,7 @@ void reply_dropper(void *ctx) {
     z_drop(z_move(cond));
 }
 
-void reply_handler(const z_loaned_reply_t *reply, void *ctx) {
+void reply_handler(z_loaned_reply_t *reply, void *ctx) {
     (void)(ctx);
     if (z_reply_is_ok(reply)) {
         const z_loaned_sample_t *sample = z_reply_ok(reply);

examples/unix/c11/z_ping.c

@@ -30,7 +30,7 @@
 static z_owned_condvar_t cond;
 static z_owned_mutex_t mutex;
 
-void callback(const z_loaned_sample_t* sample, void* context) {
+void callback(z_loaned_sample_t* sample, void* context) {
     (void)sample;
     (void)context;
     z_condvar_signal(z_loan_mut(cond));

examples/unix/c11/z_pong.c

@@ -16,7 +16,7 @@
 #include "zenoh-pico.h"
 
 #if Z_FEATURE_SUBSCRIPTION == 1 && Z_FEATURE_PUBLICATION == 1
-void callback(const z_loaned_sample_t* sample, void* context) {
+void callback(z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_loan(*(z_owned_publisher_t*)context);
     z_owned_bytes_t payload;
     z_bytes_clone(&payload, z_sample_payload(sample));

examples/unix/c11/z_queryable.c

@@ -26,7 +26,7 @@ static int msg_nb = 0;
 static enum { REPLY_DATA, REPLY_DELETE, REPLY_ERR } reply_kind = REPLY_DATA;
 bool reply_err = false;
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);

examples/unix/c11/z_queryable_attachment.c

@@ -104,7 +104,7 @@ void drop_attachment(kv_pairs_rx_t *kvp) {
     z_free(kvp->data);
 }
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);

examples/unix/c11/z_scout.c

@@ -61,7 +61,7 @@ void fprinthello(FILE *stream, const z_loaned_hello_t *hello) {
     fprintf(stream, " }");
 }
 
-void callback(const z_loaned_hello_t *hello, void *context) {
+void callback(z_loaned_hello_t *hello, void *context) {
     fprinthello(stdout, hello);
     fprintf(stdout, "\n");
     (*(int *)context)++;

examples/unix/c11/z_sub.c

@@ -24,7 +24,7 @@
 
 static int msg_nb = 0;
 
-void data_handler(const z_loaned_sample_t *sample, void *ctx) {
+void data_handler(z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/unix/c11/z_sub_attachment.c

@@ -70,7 +70,7 @@ void drop_attachment(kv_pairs_t *kvp) {
     z_free(kvp->data);
 }
 
-void data_handler(const z_loaned_sample_t *sample, void *ctx) {
+void data_handler(z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/unix/c11/z_sub_st.c

@@ -23,7 +23,7 @@
 
 static int msg_nb = 0;
 
-void data_handler(const z_loaned_sample_t *sample, void *ctx) {
+void data_handler(z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/unix/c11/z_sub_thr.c

@@ -39,7 +39,7 @@ z_stats_t *z_stats_make(void) {
     return stats;
 }
 
-void on_sample(const z_loaned_sample_t *sample, void *context) {
+void on_sample(z_loaned_sample_t *sample, void *context) {
     (void)sample;
     z_stats_t *stats = (z_stats_t *)context;
     stats->count++;

examples/unix/c99/z_get.c

@@ -29,7 +29,7 @@ void reply_dropper(void *ctx) {
     z_condvar_drop(z_condvar_move(&cond));
 }
 
-void reply_handler(const z_loaned_reply_t *reply, void *ctx) {
+void reply_handler(z_loaned_reply_t *reply, void *ctx) {
     (void)(ctx);
     if (z_reply_is_ok(reply)) {
         const z_loaned_sample_t *sample = z_reply_ok(reply);

examples/unix/c99/z_ping.c

@@ -31,7 +31,7 @@
 static z_owned_condvar_t cond;
 static z_owned_mutex_t mutex;
 
-void callback(const z_loaned_sample_t* sample, void* context) {
+void callback(z_loaned_sample_t* sample, void* context) {
     (void)sample;
     (void)context;
     z_condvar_signal(z_condvar_loan_mut(&cond));

examples/unix/c99/z_pong.c

@@ -17,7 +17,7 @@
 #include "zenoh-pico/api/primitives.h"
 
 #if Z_FEATURE_SUBSCRIPTION == 1 && Z_FEATURE_PUBLICATION == 1
-void callback(const z_loaned_sample_t* sample, void* context) {
+void callback(z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_publisher_loan((z_owned_publisher_t*)context);
     z_owned_bytes_t payload;
     z_bytes_clone(&payload, z_sample_payload(sample));

examples/unix/c99/z_queryable.c

@@ -22,7 +22,7 @@
 const char *keyexpr = "demo/example/zenoh-pico-queryable";
 const char *value = "Queryable from Pico!";
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);

examples/unix/c99/z_scout.c

@@ -60,7 +60,7 @@ void fprinthello(FILE *stream, const z_loaned_hello_t *hello) {
     fprintf(stream, " }");
 }
 
-void callback(const z_loaned_hello_t *hello, void *context) {
+void callback(z_loaned_hello_t *hello, void *context) {
     fprinthello(stdout, hello);
     fprintf(stdout, "\n");
     (*(int *)context)++;

examples/unix/c99/z_sub.c

@@ -20,7 +20,7 @@
 #include <zenoh-pico.h>
 
 #if Z_FEATURE_SUBSCRIPTION == 1
-void data_handler(const z_loaned_sample_t *sample, void *arg) {
+void data_handler(z_loaned_sample_t *sample, void *arg) {
     (void)(arg);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/unix/c99/z_sub_st.c

@@ -23,7 +23,7 @@
 
 static int msg_nb = 0;
 
-void data_handler(const z_loaned_sample_t *sample, void *arg) {
+void data_handler(z_loaned_sample_t *sample, void *arg) {
     (void)(arg);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/windows/z_get.c

@@ -28,7 +28,7 @@ void reply_dropper(void *ctx) {
     z_drop(z_move(cond));
 }
 
-void reply_handler(const z_loaned_reply_t *reply, void *ctx) {
+void reply_handler(z_loaned_reply_t *reply, void *ctx) {
     (void)(ctx);
     if (z_reply_is_ok(reply)) {
         const z_loaned_sample_t *sample = z_reply_ok(reply);

examples/windows/z_ping.c

@@ -30,7 +30,7 @@
 static z_owned_condvar_t cond;
 static z_owned_mutex_t mutex;
 
-void callback(const z_loaned_sample_t* sample, void* context) {
+void callback(z_loaned_sample_t* sample, void* context) {
     (void)sample;
     (void)context;
     z_condvar_signal(z_loan_mut(cond));

examples/windows/z_pong.c

@@ -16,7 +16,7 @@
 #include "zenoh-pico.h"
 
 #if Z_FEATURE_SUBSCRIPTION == 1 && Z_FEATURE_PUBLICATION == 1
-void callback(const z_loaned_sample_t* sample, void* context) {
+void callback(z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_loan(*(z_owned_publisher_t*)context);
     z_owned_bytes_t payload;
     z_bytes_clone(&payload, z_sample_payload(sample));

examples/windows/z_queryable.c

@@ -21,7 +21,7 @@
 const char *keyexpr = "demo/example/zenoh-pico-queryable";
 const char *value = "Queryable from Pico!";
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);

examples/windows/z_scout.c

@@ -60,7 +60,7 @@ void fprinthello(FILE *stream, const z_loaned_hello_t *hello) {
     fprintf(stream, " }");
 }
 
-void callback(const z_loaned_hello_t *hello, void *context) {
+void callback(z_loaned_hello_t *hello, void *context) {
     fprinthello(stdout, hello);
     fprintf(stdout, "\n");
     (*(int *)context)++;

examples/windows/z_sub.c

@@ -19,7 +19,7 @@
 #include <zenoh-pico.h>
 
 #if Z_FEATURE_SUBSCRIPTION == 1
-void data_handler(const z_loaned_sample_t *sample, void *ctx) {
+void data_handler(z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/windows/z_sub_st.c

@@ -22,7 +22,7 @@
 int msg_nb = 0;
 
 #if Z_FEATURE_SUBSCRIPTION == 1
-void data_handler(const z_loaned_sample_t *sample, void *ctx) {
+void data_handler(z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_sample_keyexpr(sample), &keystr);

examples/zephyr/z_get.c

@@ -34,7 +34,7 @@
 
 void reply_dropper(void *ctx) { printf(" >> Received query final notification\n"); }
 
-void reply_handler(const z_loaned_reply_t *oreply, void *ctx) {
+void reply_handler(z_loaned_reply_t *oreply, void *ctx) {
     if (z_reply_is_ok(oreply)) {
         const z_loaned_sample_t *sample = z_reply_ok(oreply);
         z_view_string_t keystr;

examples/zephyr/z_queryable.c

@@ -31,7 +31,7 @@
 #define KEYEXPR "demo/example/zenoh-pico-queryable"
 #define VALUE "[STSTM32]{nucleo-F767ZI} Queryable from Zenoh-Pico!"
 
-void query_handler(const z_loaned_query_t *query, void *ctx) {
+void query_handler(z_loaned_query_t *query, void *ctx) {
     (void)(ctx);
     z_view_string_t keystr;
     z_keyexpr_as_view_string(z_query_keyexpr(query), &keystr);