feat: update tests and examples

eclipse-zenoh · Jun 11, 2024 · c1e8c80 · c1e8c80
1 parent ed613b7
commit c1e8c80
Show file tree

Hide file tree

Showing 41 changed files with 142 additions and 128 deletions.
diff --git a/examples/arduino/z_get.ino b/examples/arduino/z_get.ino
@@ -119,7 +119,7 @@ void loop() {
     if (strcmp(VALUE, "") != 0) {
         z_view_string_t value_str;
         z_view_string_wrap(&value_str, VALUE);
-        z_owned_slice_t payload;
+        z_owned_bytes_t payload;
         z_bytes_encode_from_string(&payload, z_view_string_loan(&value_str));
         opts.payload = &payload;
     }

diff --git a/examples/arduino/z_queryable.ino b/examples/arduino/z_queryable.ino
@@ -43,8 +43,8 @@ void query_handler(const z_loaned_query_t *query, void *arg) {
     Serial.println("'");
 
     // Process value
-    const z_loaned_slice_t *payload = z_value_payload(z_query_value(query));
-    if (z_slice_len(payload) > 0) {
+    const z_loaned_bytes_t *payload = z_value_payload(z_query_value(query));
+    if (z_bytes_len(payload) > 0) {
         z_owned_string_t payload_string;
         z_bytes_decode_into_string(payload, &payload_string);
         Serial.print("     with value '");
@@ -59,10 +59,10 @@ void query_handler(const z_loaned_query_t *query, void *arg) {
     // Reply value encoding
     z_view_string_t reply_str;
     z_view_string_wrap(&reply_str, VALUE);
-    z_owned_slice_t reply_payload;
+    z_owned_bytes_t reply_payload;
     z_bytes_encode_from_string(&reply_payload, z_view_string_loan(&reply_str));
 
-    z_query_reply(query, z_view_keyexpr_loan(&ke), z_slice_move(&reply_payload), NULL);
+    z_query_reply(query, z_view_keyexpr_loan(&ke), z_bytes_move(&reply_payload), NULL);
 
     z_string_drop(z_string_move(&keystr));
 }

diff --git a/examples/arduino/z_sub.ino b/examples/arduino/z_sub.ino
@@ -37,8 +37,8 @@
 void data_handler(const z_loaned_sample_t *sample, void *arg) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *slice = z_sample_payload(sample);
-    std::string val((const char *)z_slice_data(slice), z_slice_len(slice));
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
+    std::string val((const char *)z_bytes_data(payload), z_bytes_len(payload));
 
     Serial.print(" >> [Subscription listener] Received (");
     Serial.print(z_string_data(z_string_loan(&keystr)));

diff --git a/examples/espidf/z_get.c b/examples/espidf/z_get.c
@@ -166,7 +166,7 @@ void app_main() {
         if (strcmp(VALUE, "") != 0) {
             z_view_string_t value_str;
             z_view_string_wrap(&value_str, VALUE);
-            z_owned_slice_t payload;
+            z_owned_bytes_t payload;
             z_bytes_encode_from_string(&payload, z_loan(value_str));
             opts.payload = &payload;
         }

diff --git a/examples/espidf/z_queryable.c b/examples/espidf/z_queryable.c
@@ -110,8 +110,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     printf(" >> [Queryable handler] Received Query '%s%.*s'\n", z_string_data(z_loan(keystr)), (int)z_loan(params)->len,
            z_loan(params)->val);
     // Process value
-    const z_loaned_slice_t *payload = z_value_payload(z_query_value(query));
-    if (z_slice_len(payload) > 0) {
+    const z_loaned_bytes_t *payload = z_value_payload(z_query_value(query));
+    if (z_bytes_len(payload) > 0) {
         z_owned_string_t payload_string;
         z_bytes_decode_into_string(payload, &payload_string);
         printf("     with value '%s'\n", z_string_data(z_loan(payload_string)));
@@ -122,7 +122,7 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     // Reply value encoding
     z_view_string_t reply_str;
     z_view_string_wrap(&reply_str, VALUE);
-    z_owned_slice_t reply_payload;
+    z_owned_bytes_t reply_payload;
     z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
 
     z_query_reply(query, z_loan(ke), z_move(reply_payload), NULL);

diff --git a/examples/espidf/z_sub.c b/examples/espidf/z_sub.c
@@ -103,9 +103,9 @@ void wifi_init_sta(void) {
 void data_handler(const z_loaned_sample_t* sample, void* arg) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t* payload = z_sample_payload(sample);
+    const z_loaned_bytes_t* payload = z_sample_payload(sample);
     printf(" >> [Subscriber handler] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
-           (int)z_slice_len(payload), z_slice_data(payload));
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
 }
 

diff --git a/examples/freertos_plus_tcp/z_get.c b/examples/freertos_plus_tcp/z_get.c
@@ -90,7 +90,7 @@ void app_main(void) {
         if (strcmp(VALUE, "") != 0) {
             z_view_string_t value_str;
             z_view_string_wrap(&value_str, VALUE);
-            z_owned_slice_t payload;
+            z_owned_bytes_t payload;
             z_bytes_encode_from_string(&payload, z_loan(value_str));
             opts.payload = &payload;
         }

diff --git a/examples/freertos_plus_tcp/z_queryable.c b/examples/freertos_plus_tcp/z_queryable.c
@@ -38,8 +38,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     printf(" >> [Queryable handler] Received Query '%s%.*s'\n", z_string_data(z_loan(keystr)), (int)z_loan(params)->len,
            z_loan(params)->val);
     // Process value
-    const z_loaned_slice_t *payload = z_value_payload(z_query_value(query));
-    if (z_slice_len(payload) > 0) {
+    const z_loaned_bytes_t *payload = z_value_payload(z_query_value(query));
+    if (z_bytes_len(payload) > 0) {
         z_owned_string_t payload_string;
         z_bytes_decode_into_string(payload, &payload_string);
         printf("     with value '%s'\n", z_string_data(z_loan(payload_string)));
@@ -50,7 +50,7 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     // Reply value encoding
     z_view_string_t reply_str;
     z_view_string_wrap(&reply_str, VALUE);
-    z_owned_slice_t reply_payload;
+    z_owned_bytes_t reply_payload;
     z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
 
     z_query_reply(query, z_query_keyexpr(query), z_move(reply_payload), &options);

diff --git a/examples/freertos_plus_tcp/z_sub.c b/examples/freertos_plus_tcp/z_sub.c
@@ -32,9 +32,9 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_slice_len(payload),
-           z_slice_data(payload));
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
     z_drop(z_move(keystr));
 }
 

diff --git a/examples/freertos_plus_tcp/z_sub_st.c b/examples/freertos_plus_tcp/z_sub_st.c
@@ -35,9 +35,9 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_slice_len(payload),
-           z_slice_data(payload));
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
     z_drop(z_move(keystr));
     z_drop(z_move(keystr));
     msg_nb++;

diff --git a/examples/mbed/z_get.cpp b/examples/mbed/z_get.cpp
@@ -87,7 +87,7 @@ int main(int argc, char **argv) {
         if (strcmp(VALUE, "") != 0) {
             z_view_string_t value_str;
             z_view_string_wrap(&value_str, VALUE);
-            z_owned_slice_t payload;
+            z_owned_bytes_t payload;
             z_bytes_encode_from_string(&payload, z_view_string_loan(&value_str));
             opts.payload = &payload;
         }

diff --git a/examples/mbed/z_queryable.cpp b/examples/mbed/z_queryable.cpp
@@ -40,8 +40,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     printf(" >> [Queryable handler] Received Query '%s%.*s'\n", z_string_data(z_string_loan(&keystr)),
            (int)z_view_string_loan(&pred)->len, z_view_string_loan(&pred)->val);
     // Process value
-    const z_loaned_slice_t *payload = z_value_payload(z_query_value(query));
-    if (z_slice_len(payload) > 0) {
+    const z_loaned_bytes_t *payload = z_value_payload(z_query_value(query));
+    if (z_bytes_len(payload) > 0) {
         z_owned_string_t payload_string;
         z_bytes_decode_into_string(payload, &payload_string);
         printf("     with value '%s'\n", z_string_data(z_string_loan(&payload_string)));
@@ -50,10 +50,10 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     // Reply value encoding
     z_view_string_t reply_str;
     z_view_string_wrap(&reply_str, VALUE);
-    z_owned_slice_t reply_payload;
+    z_owned_bytes_t reply_payload;
     z_bytes_encode_from_string(&reply_payload, z_view_string_loan(&reply_str));
 
-    z_query_reply(query, z_query_keyexpr(query), z_slice_move(&reply_payload), NULL);
+    z_query_reply(query, z_query_keyexpr(query), z_bytes_move(&reply_payload), NULL);
     z_string_drop(z_string_move(&keystr));
 }
 

diff --git a/examples/mbed/z_sub.cpp b/examples/mbed/z_sub.cpp
@@ -33,9 +33,9 @@
 void data_handler(const z_loaned_sample_t *sample, void *arg) {
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *payload = z_sample_payload(sample);
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
     printf(" >> [Subscriber handler] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
-           (int)z_slice_len(payload), z_slice_data(payload));
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
 }
 

diff --git a/examples/unix/c11/z_get_channel.c b/examples/unix/c11/z_get_channel.c
@@ -94,7 +94,7 @@ int main(int argc, char **argv) {
     if (value != NULL) {
         z_view_string_t value_str;
         z_view_string_wrap(&value_str, value);
-        z_owned_slice_t payload;
+        z_owned_bytes_t payload;
         z_bytes_encode_from_string(&payload, z_loan(value_str));
         opts.payload = &payload;
     }

diff --git a/examples/unix/c11/z_pong.c b/examples/unix/c11/z_pong.c
@@ -18,8 +18,8 @@
 #if Z_FEATURE_SUBSCRIPTION == 1 && Z_FEATURE_PUBLICATION == 1
 void callback(const z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_loan(*(z_owned_publisher_t*)context);
-    const z_loaned_slice_t* payload = z_sample_payload(sample);
-    z_publisher_put(pub, z_slice_data(payload), z_slice_len(payload), NULL);
+    const z_loaned_bytes_t* payload = z_sample_payload(sample);
+    z_publisher_put(pub, z_bytes_data(payload), z_bytes_len(payload), NULL);
 }
 void drop(void* context) {
     z_owned_publisher_t* pub = (z_owned_publisher_t*)context;

diff --git a/examples/unix/c11/z_pull.c b/examples/unix/c11/z_pull.c
@@ -90,9 +90,9 @@ int main(int argc, char **argv) {
         for (z_call(channel.try_recv, &sample); z_check(sample); z_call(channel.try_recv, &sample)) {
             z_owned_string_t keystr;
             z_keyexpr_to_string(z_sample_keyexpr(z_loan(sample)), &keystr);
-            const z_loaned_slice_t *payload = z_sample_payload(z_loan(sample));
-            printf(">> [Subscriber] Pulled ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_slice_len(payload),
-                   z_slice_data(payload));
+            const z_loaned_bytes_t *payload = z_sample_payload(z_loan(sample));
+            printf(">> [Subscriber] Pulled ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+                   z_bytes_data(payload));
             z_drop(z_move(keystr));
             z_drop(z_move(sample));
         }

diff --git a/examples/unix/c11/z_queryable.c b/examples/unix/c11/z_queryable.c
@@ -41,7 +41,7 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
            z_loan(params)->val);
     // Process value
     const z_loaned_bytes_t *payload = z_value_payload(z_query_value(query));
-    if (z_slice_len(payload) > 0) {
+    if (z_bytes_len(payload) > 0) {
         z_owned_string_t payload_string;
         z_bytes_decode_into_string(payload, &payload_string);
         printf("     with value '%s'\n", z_string_data(z_loan(payload_string)));
@@ -73,7 +73,7 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     // Reply value encoding
     z_view_string_t reply_str;
     z_view_string_wrap(&reply_str, value);
-    z_owned_slice_t reply_payload;
+    z_owned_bytes_t reply_payload;
     z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
 
     z_query_reply(query, z_query_keyexpr(query), z_move(reply_payload), &options);

diff --git a/examples/unix/c11/z_queryable_channel.c b/examples/unix/c11/z_queryable_channel.c
@@ -106,8 +106,8 @@ int main(int argc, char **argv) {
         z_query_parameters(q, &params);
         printf(" >> [Queryable handler] Received Query '%s%.*s'\n", z_string_data(z_loan(keystr)),
                (int)z_loan(params)->len, z_loan(params)->val);
-        const z_loaned_slice_t *payload = z_value_payload(z_query_value(z_loan(query)));
-        if (z_slice_len(payload) > 0) {
+        const z_loaned_bytes_t *payload = z_value_payload(z_query_value(z_loan(query)));
+        if (z_bytes_len(payload) > 0) {
             z_owned_string_t payload_string;
             z_bytes_decode_into_string(payload, &payload_string);
             printf("     with value '%s'\n", z_string_data(z_loan(payload_string)));
@@ -118,7 +118,7 @@ int main(int argc, char **argv) {
         // Reply value encoding
         z_view_string_t reply_str;
         z_view_string_wrap(&reply_str, value);
-        z_owned_slice_t reply_payload;
+        z_owned_bytes_t reply_payload;
         z_bytes_encode_from_string(&reply_payload, z_loan(reply_str));
 
         z_query_reply(q, z_query_keyexpr(q), z_move(reply_payload), &options);

diff --git a/examples/unix/c11/z_sub.c b/examples/unix/c11/z_sub.c
@@ -36,9 +36,9 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_slice_len(payload),
-           z_slice_data(payload));
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
 #if Z_FEATURE_ATTACHMENT == 1
     z_attachment_t attachment = z_sample_attachment(sample);
     if (z_attachment_check(&attachment)) {

diff --git a/examples/unix/c11/z_sub_channel.c b/examples/unix/c11/z_sub_channel.c
@@ -80,9 +80,9 @@ int main(int argc, char **argv) {
     for (z_call(channel.recv, &sample); z_check(sample); z_call(channel.recv, &sample)) {
         z_owned_string_t keystr;
         z_keyexpr_to_string(z_sample_keyexpr(z_loan(sample)), &keystr);
-        const z_loaned_slice_t *payload = z_sample_payload(z_loan(sample));
-        printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_slice_len(payload),
-               z_slice_data(payload));
+        const z_loaned_bytes_t *payload = z_sample_payload(z_loan(sample));
+        printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+               z_bytes_data(payload));
         z_drop(z_move(keystr));
         z_drop(z_move(sample));
         z_null(&sample);

diff --git a/examples/unix/c11/z_sub_st.c b/examples/unix/c11/z_sub_st.c
@@ -27,9 +27,9 @@ void data_handler(const z_loaned_sample_t *sample, void *ctx) {
     (void)(ctx);
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *payload = z_sample_payload(sample);
-    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_slice_len(payload),
-           z_slice_data(payload));
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
+    printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_loan(keystr)), (int)z_bytes_len(payload),
+           z_bytes_data(payload));
     z_drop(z_move(keystr));
     msg_nb++;
 }

diff --git a/examples/unix/c99/z_get.c b/examples/unix/c99/z_get.c
@@ -125,7 +125,7 @@ int main(int argc, char **argv) {
     if (value != NULL) {
         z_view_string_t value_str;
         z_view_string_wrap(&value_str, value);
-        z_owned_slice_t payload;
+        z_owned_bytes_t payload;
         z_bytes_encode_from_string(&payload, z_view_string_loan(&value_str));
         opts.payload = &payload;
     }

diff --git a/examples/unix/c99/z_pong.c b/examples/unix/c99/z_pong.c
@@ -19,8 +19,8 @@
 #if Z_FEATURE_SUBSCRIPTION == 1 && Z_FEATURE_PUBLICATION == 1
 void callback(const z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_publisher_loan((z_owned_publisher_t*)context);
-    const z_loaned_slice_t* payload = z_sample_payload(sample);
-    z_publisher_put(pub, z_slice_data(payload), z_slice_len(payload), NULL);
+    const z_loaned_bytes_t* payload = z_sample_payload(sample);
+    z_publisher_put(pub, z_bytes_data(payload), z_bytes_len(payload), NULL);
 }
 void drop(void* context) {
     z_owned_publisher_t* pub = (z_owned_publisher_t*)context;

diff --git a/examples/unix/c99/z_queryable.c b/examples/unix/c99/z_queryable.c
@@ -31,8 +31,8 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     printf(" >> [Queryable handler] Received Query '%s%.*s'\n", z_string_data(z_string_loan(&keystr)),
            (int)z_view_string_loan(&params)->len, z_view_string_loan(&params)->val);
     // Process value
-    const z_loaned_slice_t *payload = z_value_payload(z_query_value(query));
-    if (z_slice_len(payload) > 0) {
+    const z_loaned_bytes_t *payload = z_value_payload(z_query_value(query));
+    if (z_bytes_len(payload) > 0) {
         z_owned_string_t payload_string;
         z_bytes_decode_into_string(payload, &payload_string);
         printf("     with value '%s'\n", z_string_data(z_string_loan(&payload_string)));
@@ -48,10 +48,10 @@ void query_handler(const z_loaned_query_t *query, void *ctx) {
     // Reply value encoding
     z_view_string_t reply_str;
     z_view_string_wrap(&reply_str, value);
-    z_owned_slice_t reply_payload;
+    z_owned_bytes_t reply_payload;
     z_bytes_encode_from_string(&reply_payload, z_view_string_loan(&reply_str));
 
-    z_query_reply(query, z_query_keyexpr(query), z_slice_move(&reply_payload), &options);
+    z_query_reply(query, z_query_keyexpr(query), z_bytes_move(&reply_payload), &options);
     z_string_drop(z_string_move(&keystr));
 }
 

diff --git a/examples/unix/c99/z_sub.c b/examples/unix/c99/z_sub.c
@@ -24,9 +24,9 @@ void data_handler(const z_loaned_sample_t *sample, void *arg) {
     (void)(arg);
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *payload = z_sample_payload(sample);
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
     printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
-           (int)z_slice_len(payload), z_slice_data(payload));
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
 }
 

diff --git a/examples/unix/c99/z_sub_st.c b/examples/unix/c99/z_sub_st.c
@@ -27,9 +27,9 @@ void data_handler(const z_loaned_sample_t *sample, void *arg) {
     (void)(arg);
     z_owned_string_t keystr;
     z_keyexpr_to_string(z_sample_keyexpr(sample), &keystr);
-    const z_loaned_slice_t *payload = z_sample_payload(sample);
+    const z_loaned_bytes_t *payload = z_sample_payload(sample);
     printf(">> [Subscriber] Received ('%s': '%.*s')\n", z_string_data(z_string_loan(&keystr)),
-           (int)z_slice_len(payload), z_slice_data(payload));
+           (int)z_bytes_len(payload), z_bytes_data(payload));
     z_string_drop(z_string_move(&keystr));
     msg_nb++;
 }

diff --git a/examples/windows/z_get.c b/examples/windows/z_get.c
@@ -89,7 +89,7 @@ int main(int argc, char **argv) {
     if (value != NULL) {
         z_view_string_t value_str;
         z_view_string_wrap(&value_str, value);
-        z_owned_slice_t payload;
+        z_owned_bytes_t payload;
         z_bytes_encode_from_string(&payload, z_loan(value_str));
         opts.payload = &payload;
     }

diff --git a/examples/windows/z_pong.c b/examples/windows/z_pong.c
@@ -18,8 +18,8 @@
 #if Z_FEATURE_SUBSCRIPTION == 1 && Z_FEATURE_PUBLICATION == 1
 void callback(const z_loaned_sample_t* sample, void* context) {
     const z_loaned_publisher_t* pub = z_loan(*(z_owned_publisher_t*)context);
-    const z_loaned_slice_t* payload = z_sample_payload(sample);
-    z_publisher_put(pub, z_slice_data(payload), z_slice_len(payload), NULL);
+    const z_loaned_bytes_t* payload = z_sample_payload(sample);
+    z_publisher_put(pub, z_bytes_data(payload), z_bytes_len(payload), NULL);
 }
 void drop(void* context) {
     z_owned_publisher_t* pub = (z_owned_publisher_t*)context;