@@ -156,7 +156,6 @@ pub(crate) struct SessionState {
156
156
pub ( crate ) aggregated_subscribers : Vec < OwnedKeyExpr > ,
157
157
pub ( crate ) aggregated_publishers : Vec < OwnedKeyExpr > ,
158
158
pub ( crate ) publisher_qos_tree : KeBoxTree < PublisherQoSConfig > ,
159
- #[ cfg( feature = "unstable" ) ]
160
159
pub ( crate ) closing_callbacks : ClosingCallbackList ,
161
160
}
162
161
@@ -192,7 +191,6 @@ impl SessionState {
192
191
aggregated_subscribers,
193
192
aggregated_publishers,
194
193
publisher_qos_tree,
195
- #[ cfg( feature = "unstable" ) ]
196
194
closing_callbacks : Default :: default ( ) ,
197
195
}
198
196
}
@@ -1260,6 +1258,8 @@ impl Session {
1260
1258
/// the callback with [`unregister_closing_callback`](Self::unregister_closing_callback). If
1261
1259
/// the session is already closed, the callback is returned in an error.
1262
1260
///
1261
+ /// Execution order of callbacks is unspecified.
1262
+ ///
1263
1263
/// # Examples
1264
1264
///
1265
1265
/// ```rust
@@ -1272,7 +1272,7 @@ impl Session {
1272
1272
/// }
1273
1273
/// # }
1274
1274
/// ```
1275
- #[ zenoh_macros:: unstable ]
1275
+ #[ zenoh_macros:: internal ]
1276
1276
pub fn register_closing_callback < F : FnOnce ( ) + Send + Sync + ' static > (
1277
1277
& self ,
1278
1278
callback : F ,
@@ -1303,7 +1303,7 @@ impl Session {
1303
1303
/// session.unregister_closing_callback(id);
1304
1304
/// # }
1305
1305
/// ```
1306
- #[ zenoh_macros:: unstable ]
1306
+ #[ zenoh_macros:: internal ]
1307
1307
pub fn unregister_closing_callback ( & self , callback_id : ClosingCallbackId ) {
1308
1308
let mut state = zwrite ! ( self . 0 . state) ;
1309
1309
state. closing_callbacks . remove_callback ( callback_id) ;
@@ -3286,14 +3286,12 @@ impl Closeable for Session {
3286
3286
}
3287
3287
}
3288
3288
3289
- #[ cfg( feature = "unstable" ) ]
3290
3289
#[ derive( Default ) ]
3291
3290
pub ( crate ) struct ClosingCallbackList {
3292
3291
callbacks : slab:: Slab < ClosingCallback > ,
3293
3292
generation : usize ,
3294
3293
}
3295
3294
3296
- #[ cfg( feature = "unstable" ) ]
3297
3295
impl ClosingCallbackList {
3298
3296
fn insert_callback ( & mut self , callback : Box < dyn FnOnce ( ) + Send + Sync > ) -> ClosingCallbackId {
3299
3297
let generation = self . generation ;
@@ -3312,7 +3310,6 @@ impl ClosingCallbackList {
3312
3310
}
3313
3311
}
3314
3312
3315
- #[ cfg( feature = "unstable" ) ]
3316
3313
impl Drop for ClosingCallbackList {
3317
3314
fn drop ( & mut self ) {
3318
3315
for cb in self . callbacks . drain ( ) {
@@ -3321,7 +3318,6 @@ impl Drop for ClosingCallbackList {
3321
3318
}
3322
3319
}
3323
3320
3324
- #[ cfg( feature = "unstable" ) ]
3325
3321
struct ClosingCallback {
3326
3322
callback : Box < dyn FnOnce ( ) + Send + Sync > ,
3327
3323
generation : usize ,
@@ -3330,7 +3326,6 @@ struct ClosingCallback {
3330
3326
/// The id of a registered session closing callback.
3331
3327
///
3332
3328
/// See [`Session::register_closing_callback`].
3333
- #[ zenoh_macros:: unstable]
3334
3329
#[ derive( Debug , Clone , PartialEq , Eq ) ]
3335
3330
pub struct ClosingCallbackId {
3336
3331
index : usize ,
0 commit comments