Skip to content

Commit 47be88d

Browse files
committed
chore(meta/watch): refine var names
1 parent 367a714 commit 47be88d

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

Diff for: src/meta/service/src/api/grpc/grpc_service.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -245,8 +245,8 @@ impl MetaService for MetaServiceImpl {
245245
let add_res = mn.add_watcher(request.into_inner(), tx).await;
246246

247247
match add_res {
248-
Ok(watcher_info) => {
249-
let stream = WatchStream::new(rx, watcher_info, mn.dispatcher_handle.clone());
248+
Ok(watcher) => {
249+
let stream = WatchStream::new(rx, watcher, mn.dispatcher_handle.clone());
250250
Ok(Response::new(Box::pin(stream) as Self::WatchStream))
251251
}
252252
Err(e) => {

Diff for: src/meta/service/src/watcher/watcher_stream.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -92,10 +92,10 @@ impl<T> Drop for WatchStream<T> {
9292

9393
impl<T> WatchStream<T> {
9494
/// Create a new `WatcherStream`.
95-
pub fn new(rx: Receiver<T>, watcher_info: Watcher, dispatcher: EventDispatcherHandle) -> Self {
95+
pub fn new(rx: Receiver<T>, watcher: Watcher, dispatcher: EventDispatcherHandle) -> Self {
9696
Self {
9797
inner: rx,
98-
watcher: watcher_info,
98+
watcher,
9999
dispatcher,
100100
}
101101
}

0 commit comments

Comments
 (0)