Skip to content

Commit 72d8a45

Browse files
committed
update API
Signed-off-by: Esteve Fernandez <[email protected]>
1 parent f4ae75d commit 72d8a45

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

rclrs/src/dynamic_message/dynamic_subscription.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ use super::{
1313
use crate::rcl_bindings::*;
1414
use crate::{
1515
MessageInfo, Node, NodeHandle, RclPrimitive, RclPrimitiveHandle, RclPrimitiveKind, RclrsError,
16-
RclrsErrorFilter, SubscriptionHandle, SubscriptionOptions, ToResult, Waitable,
16+
RclrsErrorFilter, SubscriptionHandle, SubscriptionOptions, ReadyKind, ToResult, Waitable,
1717
WaitableLifecycle, WorkScope, Worker, WorkerCommands, ENTITY_LIFECYCLE_MUTEX,
1818
};
1919

@@ -215,7 +215,8 @@ impl<Payload> DynamicSubscriptionExecutable<Payload> {
215215
}
216216

217217
impl<Payload: 'static> RclPrimitive for DynamicSubscriptionExecutable<Payload> {
218-
unsafe fn execute(&mut self, payload: &mut dyn Any) -> Result<(), RclrsError> {
218+
unsafe fn execute(&mut self, ready: ReadyKind, payload: &mut dyn Any) -> Result<(), RclrsError> {
219+
ready.for_basic()?;
219220
self.callback
220221
.lock()
221222
.unwrap()

0 commit comments

Comments
 (0)