test: integration to tests/, serializer with tokio::test (#354)

* test: move to tests/

* refactor: tokio test, rm `Stream::push`

* test: move integration level test

* test: move mocking code

* test: reorg

uplink/src/base/bridge/data_lane.rs

@@ -88,7 +88,7 @@ impl DataBridge {
 /// Handle for apps to send action status to bridge
 #[derive(Debug, Clone)]
 pub struct DataTx {
-    pub(crate) inner: Sender<Payload>,
+    pub inner: Sender<Payload>,
 }
 
 impl DataTx {

uplink/src/base/bridge/mod.rs

@@ -8,10 +8,10 @@ mod actions_lane;
 mod data_lane;
 mod delaymap;
 mod metrics;
-pub(crate) mod stream;
+pub mod stream;
 mod streams;
 
-use actions_lane::{ActionsBridge, Error};
+pub use actions_lane::{ActionsBridge, Error};
 pub use actions_lane::{CtrlTx as ActionsLaneCtrlTx, StatusTx};
 use data_lane::DataBridge;
 pub use data_lane::{CtrlTx as DataLaneCtrlTx, DataTx};

uplink/src/base/bridge/stream.rs

@@ -148,27 +148,6 @@ where
 
         Ok(status)
     }
-
-    #[cfg(test)]
-    /// Push data into buffer and trigger sync channel send on max_batch_size.
-    /// Returns [`StreamStatus`].
-    pub fn push(&mut self, data: T) -> Result<StreamStatus, Error> {
-        if let Some(buf) = self.add(data)? {
-            self.tx.send(Box::new(buf))?;
-            return Ok(StreamStatus::Flushed);
-        }
-
-        let status = match self.len() {
-            1 => StreamStatus::Init(self.config.flush_period),
-            len => StreamStatus::Partial(len),
-        };
-
-        Ok(status)
-    }
-
-    // pub fn metrics(&self) -> StreamMetrics {
-    //     self.metrics.clone()
-    // }
 }
 
 /// Buffer is an abstraction of a collection that serializer receives.