chore: ~bump ver v0.4.0

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "watcher"
 description = "subscribe data changes"
-version = "0.3.0"
+version = "0.4.0"
 authors = ["Databend Authors <opensource@datafuselabs.com>"]
 license = "Apache-2.0"
 edition = "2021"

src/testing.rs

@@ -30,7 +30,7 @@ impl TypeConfig for UTTypes {
     type Response = (String, Option<String>, Option<String>);
     type Error = io::Error;
 
-    fn new_flush_response(key: KeyOf<Self>, value: ValueOf<Self>) -> Self::Response {
+    fn new_initialize_response(key: KeyOf<Self>, value: ValueOf<Self>) -> Self::Response {
         (key, None, Some(value))
     }
 

src/type_config.rs

@@ -67,8 +67,8 @@ where Self: Debug + Clone + Copy + Sized + 'static
     /// The type of errors returned to watchers.
     type Error: Error + Send + 'static;
 
-    /// Create a new response instance from existent key value pair.
-    fn new_flush_response(key: KeyOf<Self>, value: ValueOf<Self>) -> Self::Response;
+    /// Create a new response instance from existent key value pair, for initialization.
+    fn new_initialize_response(key: KeyOf<Self>, value: ValueOf<Self>) -> Self::Response;
 
     /// Create a response instance from a key-value change.
     fn new_change_response(change: KVChange<Self>) -> Self::Response;

src/util.rs

@@ -36,9 +36,9 @@ use crate::WatchResult;
 /// Wraps a tokio mpsc Sender in a Sink that can receive `KeySeqVResult` items.
 /// Each item is converted before being sent.
 ///
-/// This function is used for initial-flush, not for actual key-value change, i.e.,
+/// This function is used for initialization-flush, not for actual key-value change, i.e.,
 /// an actual key-value change contains 3 element: key, before-value and after-value.
-pub fn new_flush_sink<C>(
+pub fn new_initialization_sink<C>(
     tx: mpsc::Sender<WatchResult<C>>,
     ctx: &'static str,
 ) -> impl Sink<KVResult<C>, Error = PollSendError<WatchResult<C>>> + Send + 'static
@@ -50,7 +50,7 @@ where
     let snk = assert_sink::<WatchResult<C>, _, _>(snk);
 
     let snk = snk.with(move |res: KVResult<C>| {
-        let watch_result = kv_result_to_flush_result::<C>(res, ctx);
+        let watch_result = kv_result_to_initialization_result::<C>(res, ctx);
         futures::future::ready(Ok::<_, PollSendError<_>>(watch_result))
     });
 
@@ -86,15 +86,15 @@ where
     }
 }
 
-/// Converts a key-value result to a initial-flush watch result.
+/// Converts a key-value result to an initialization-flush watch result.
 ///
 /// Transforms a [`KVResult`] into a [`WatchResult`].
 /// Error is converted by the application defined method `data_error`
-fn kv_result_to_flush_result<C>(input: KVResult<C>, ctx: &'static str) -> WatchResult<C>
+fn kv_result_to_initialization_result<C>(input: KVResult<C>, ctx: &'static str) -> WatchResult<C>
 where C: TypeConfig {
     match input {
         Ok((key, value)) => {
-            let resp = C::new_flush_response(key, value);
+            let resp = C::new_initialize_response(key, value);
             Ok(resp)
         }
         Err(err) => {

tests/it/dispatcher.rs

@@ -47,7 +47,7 @@ impl TypeConfig for Types {
     type Response = (String, Option<String>, Option<String>);
     type Error = io::Error;
 
-    fn new_flush_response(key: KeyOf<Self>, value: ValueOf<Self>) -> Self::Response {
+    fn new_initialize_response(key: KeyOf<Self>, value: ValueOf<Self>) -> Self::Response {
         (key, None, Some(value))
     }