Skip to content

Commit c680ac0

Browse files
committed
Make Router::add_route private.
Signed-off-by: Josh Matthews <[email protected]>
1 parent 76e2c64 commit c680ac0

File tree

2 files changed

+4
-13
lines changed

2 files changed

+4
-13
lines changed

src/router.rs

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -62,11 +62,7 @@ impl RouterProxy {
6262

6363
/// Add a new (receiver, callback) pair to the router, and send a wakeup message
6464
/// to the router.
65-
///
66-
/// Consider using [add_typed_route](Self::add_typed_route) instead, which prevents
67-
/// mismatches between the receiver and callback types.
68-
#[deprecated(since = "0.19.0", note = "please use 'add_typed_route' instead")]
69-
pub fn add_route(&self, receiver: OpaqueIpcReceiver, callback: RouterHandler) {
65+
fn add_route(&self, receiver: OpaqueIpcReceiver, callback: RouterHandler) {
7066
let comm = self.comm.lock().unwrap();
7167

7268
if comm.shutdown {
@@ -81,9 +77,6 @@ impl RouterProxy {
8177

8278
/// Add a new `(receiver, callback)` pair to the router, and send a wakeup message
8379
/// to the router.
84-
///
85-
/// Unlike [add_route](Self::add_route) this method is strongly typed and guarantees
86-
/// that the `receiver` and the `callback` use the same message type.
8780
pub fn add_typed_route<T>(&self, receiver: IpcReceiver<T>, mut callback: TypedRouterHandler<T>)
8881
where
8982
T: Serialize + for<'de> Deserialize<'de> + 'static,
@@ -94,7 +87,6 @@ impl RouterProxy {
9487
callback(typed_message)
9588
};
9689

97-
#[allow(deprecated)]
9890
self.add_route(receiver.to_opaque(), Box::new(modified_callback));
9991
}
10092

src/test.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -274,11 +274,10 @@ fn router_simple_global() {
274274
tx.send(person.clone()).unwrap();
275275

276276
let (callback_fired_sender, callback_fired_receiver) = crossbeam_channel::unbounded::<Person>();
277-
#[allow(deprecated)]
278-
ROUTER.add_route(
279-
rx.to_opaque(),
277+
ROUTER.add_typed_route(
278+
rx,
280279
Box::new(move |person| {
281-
callback_fired_sender.send(person.to().unwrap()).unwrap();
280+
callback_fired_sender.send(person.unwrap()).unwrap();
282281
}),
283282
);
284283
let received_person = callback_fired_receiver.recv().unwrap();

0 commit comments

Comments
 (0)