Function init_data_engine

pub async fn init_data_engine(
    http_address: SocketAddr,
    websocket_address: SocketAddr,
) -> (Pin<Box<dyn Stream<Item = DataResponse>>>, Pin<Box<dyn Stream<Item = i32>>>)