Support changes in req-resp operations (#612)

Author: sfod

crt/aws-c-mqtt

@@ -484,20 +484,19 @@ static void s_napi_on_request_complete(napi_env env, napi_value function, void *
 }
 
 static void s_on_request_complete(
-    const struct aws_byte_cursor *response_topic,
-    const struct aws_byte_cursor *payload,
+    const struct aws_mqtt_rr_incoming_publish_event *publish_event,
     int error_code,
     void *user_data) {
 
     struct aws_napi_mqtt_request_binding *binding = user_data;
 
     if (error_code == AWS_ERROR_SUCCESS) {
-        AWS_FATAL_ASSERT(response_topic != NULL && payload != NULL);
+        AWS_FATAL_ASSERT(publish_event != NULL);
 
-        aws_byte_buf_init_copy_from_cursor(&binding->topic, binding->allocator, *response_topic);
+        aws_byte_buf_init_copy_from_cursor(&binding->topic, binding->allocator, publish_event->topic);
 
         binding->payload = aws_mem_calloc(binding->allocator, 1, sizeof(struct aws_byte_buf));
-        aws_byte_buf_init_copy_from_cursor(binding->payload, binding->allocator, *payload);
+        aws_byte_buf_init_copy_from_cursor(binding->payload, binding->allocator, publish_event->payload);
     } else {
         binding->error_code = error_code;
     }
@@ -1400,13 +1399,12 @@ static void s_napi_mqtt_streaming_operation_on_incoming_publish(
 }
 
 static void s_mqtt_streaming_operation_on_incoming_publish(
-    struct aws_byte_cursor payload,
-    struct aws_byte_cursor topic,
+    const struct aws_mqtt_rr_incoming_publish_event *publish_event,
     void *user_data) {
     struct aws_request_response_streaming_operation_binding *binding = user_data;
 
     struct on_incoming_publish_user_data *incoming_publish_ud =
-        s_on_incoming_publish_user_data_new(binding, topic, payload);
+        s_on_incoming_publish_user_data_new(binding, publish_event->topic, publish_event->payload);
     if (incoming_publish_ud == NULL) {
         return;
     }