488 int zbus_sub_wait(const struct zbus_observer *sub, const struct zbus_channel **chan,  in zbus_sub_wait()  argument
492 	_ZBUS_ASSERT(sub != NULL, "sub is required");  in zbus_sub_wait()
493 	_ZBUS_ASSERT(sub->type == ZBUS_OBSERVER_SUBSCRIBER_TYPE, "sub must be a SUBSCRIBER");  in zbus_sub_wait()
494 	_ZBUS_ASSERT(sub->queue != NULL, "sub queue is required");  in zbus_sub_wait()
497 	return k_msgq_get(sub->queue, chan, timeout);  in zbus_sub_wait()
502 int zbus_sub_wait_msg(const struct zbus_observer *sub, const struct zbus_channel **chan, void *msg,  in zbus_sub_wait_msg()  argument
506 	_ZBUS_ASSERT(sub != NULL, "sub is required");  in zbus_sub_wait_msg()
507 	_ZBUS_ASSERT(sub->type == ZBUS_OBSERVER_MSG_SUBSCRIBER_TYPE,  in zbus_sub_wait_msg()
508 		     "sub must be a MSG_SUBSCRIBER");  in zbus_sub_wait_msg()
509 	_ZBUS_ASSERT(sub->message_fifo != NULL, "sub message_fifo is required");  in zbus_sub_wait_msg()
513 	struct net_buf *buf = k_fifo_get(sub->message_fifo, timeout);  in zbus_sub_wait_msg()