pub fn spawn(&self, payload: &Payload) -> crate::error::Result<()> {
        // Clone to move into async closure
        let events_clone = payload.events.clone();
        let client = self.client.clone();
        let logger = payload.logger.clone();

        // Setup some other pre-reqs
        let uri = payload.url.as_str().to_string();
        let json = serde_json::to_string(&events_clone)?;

        let _ = self.rt.spawn(async {
            let _res = run_impl(client, logger, uri, json).await;
        });

        Ok(())
    }
/// Spawn an `Echo Event` on the inner `tokio` runtime
///
/// # Errors
///
Spawn an `Echo Event` on the inner `tokio` runtime
Spawn an ` Echo Event ` on the inner ` tokio ` runtime
pub fn spawn(&self, payload: &Payload) -> crate::error::Result<()> {
        // Clone to move into async closure
        let events_clone = payload.events.clone();
        let client = self.client.clone();
        let logger = payload.logger.clone();
        // Setup some other pre-reqs
        let uri = payload.url.as_str().to_string();
        let json = serde_json::to_string(&events_clone)?;
        let _ = self.rt.spawn(async {
            let _res = run_impl(client, logger, uri, json).await;
        });
        Ok(())
    }
pub fn spawn ( & self , payload : & Payload ) -> crate :: error :: Result < ( ) > { // Clone to move into async closure let events_clone = payload . events . clone ( ) ; let client = self . client . clone ( ) ; let logger = payload . logger . clone ( ) ; // Setup some other pre-reqs let uri = payload . url . as_str ( ) . to_string ( ) ; let json = serde_json :: to_string ( & events_clone ) ? ; let _ = self . rt . spawn ( async { let _res = run_impl ( client , logger , uri , json ) . await ; } ) ; Ok ( ( ) ) }
Spawn an `Echo Event` on the inner `tokio` runtime
Spawn an ` Echo Event ` on the inner ` tokio ` runtime
&self
payload
&Payload
&self
payload
&Payload
errors
None