diff --git a/async-opcua-client/src/lib.rs b/async-opcua-client/src/lib.rs index 0b461910..29086b1e 100644 --- a/async-opcua-client/src/lib.rs +++ b/async-opcua-client/src/lib.rs @@ -125,7 +125,7 @@ pub use config::{ClientConfig, ClientEndpoint, ClientUserToken, ANONYMOUS_USER_T pub use retry::{ExponentialBackoff, SessionRetryPolicy}; pub use session::{ Client, ConnectionSource, DataChangeCallback, DefaultRetryPolicy, DirectConnectionSource, - EventCallback, HistoryReadAction, HistoryUpdateAction, MonitoredItem, + EventCallback, HistoryReadAction, HistoryUpdateAction, MonitoredItem, MonitoredItemMap, OnSubscriptionNotification, OnSubscriptionNotificationCore, RequestRetryPolicy, Session, SessionActivity, SessionBuilder, SessionConnectMode, SessionEventLoop, SessionPollResult, Subscription, SubscriptionActivity, SubscriptionCallbacks, UARequest, diff --git a/async-opcua-client/src/session/mod.rs b/async-opcua-client/src/session/mod.rs index 21731130..5bf59497 100644 --- a/async-opcua-client/src/session/mod.rs +++ b/async-opcua-client/src/session/mod.rs @@ -63,9 +63,9 @@ use services::subscriptions::state::SubscriptionState; pub use services::subscriptions::{ CreateMonitoredItems, CreateSubscription, DataChangeCallback, DeleteMonitoredItems, DeleteSubscriptions, EventCallback, ModifyMonitoredItems, ModifySubscription, MonitoredItem, - OnSubscriptionNotification, OnSubscriptionNotificationCore, Publish, PublishLimits, Republish, - SetMonitoringMode, SetPublishingMode, SetTriggering, Subscription, SubscriptionActivity, - SubscriptionCache, SubscriptionCallbacks, SubscriptionEventLoopState, TransferSubscriptions, + MonitoredItemMap, OnSubscriptionNotification, OnSubscriptionNotificationCore, Publish, PublishLimits, + Republish, SetMonitoringMode, SetPublishingMode, SetTriggering, Subscription, + SubscriptionActivity, SubscriptionCache, SubscriptionCallbacks, SubscriptionEventLoopState, TransferSubscriptions, }; pub use services::view::{ Browse, BrowseNext, RegisterNodes, TranslateBrowsePaths, UnregisterNodes, diff --git a/async-opcua-client/src/session/services/subscriptions/mod.rs b/async-opcua-client/src/session/services/subscriptions/mod.rs index 9ec8bbd6..d4e6686a 100644 --- a/async-opcua-client/src/session/services/subscriptions/mod.rs +++ b/async-opcua-client/src/session/services/subscriptions/mod.rs @@ -344,6 +344,7 @@ impl<'a> MonitoredItemMap<'a> { } } + /// get monitored item by client handle pub fn get(&self, client_handle: u32) -> Option<&'a MonitoredItem> { self.client_handles .get(&client_handle)