Cleanup to follow C-CONV

cloudevents-sdk-actix-web/src/lib.rs

@@ -8,7 +8,7 @@
 //!
 //! #[post("/")]
 //! async fn post_event(req: HttpRequest, payload: web::Payload) -> Result<String, actix_web::Error> {
-//!     let event = req.into_event(payload).await?;
+//!     let event = req.to_event(payload).await?;
 //!     println!("Received Event: {:?}", event);
 //!     Ok(format!("{:?}", event))
 //! }

cloudevents-sdk-actix-web/src/server_request.rs

@@ -115,15 +115,15 @@ pub async fn request_to_event(
 /// Extention Trait for [`HttpRequest`] which acts as a wrapper for the function [`request_to_event()`].
 #[async_trait(?Send)]
 pub trait RequestExt {
-    async fn into_event(
+    async fn to_event(
         &self,
         mut payload: web::Payload,
     ) -> std::result::Result<Event, actix_web::error::Error>;
 }
 
 #[async_trait(?Send)]
 impl RequestExt for HttpRequest {
-    async fn into_event(
+    async fn to_event(
         &self,
         payload: web::Payload,
     ) -> std::result::Result<Event, actix_web::error::Error> {
@@ -165,7 +165,7 @@ mod tests {
             .header("ce-time", time.to_rfc3339())
             .to_http_parts();
 
-        let resp = req.into_event(web::Payload(payload)).await.unwrap();
+        let resp = req.to_event(web::Payload(payload)).await.unwrap();
         assert_eq!(expected, resp);
     }
 
@@ -197,7 +197,7 @@ mod tests {
             .set_json(&j)
             .to_http_parts();
 
-        let resp = req.into_event(web::Payload(payload)).await.unwrap();
+        let resp = req.to_event(web::Payload(payload)).await.unwrap();
         assert_eq!(expected, resp);
     }
 }

example-projects/actix-web-example/src/main.rs

@@ -5,7 +5,7 @@ use serde_json::json;
 
 #[post("/")]
 async fn post_event(req: HttpRequest, payload: web::Payload) -> Result<String, actix_web::Error> {
-    let event = req.into_event(payload).await?;
+    let event = req.to_event(payload).await?;
     println!("Received Event: {:?}", event);
     Ok(format!("{:?}", event))
 }