Enable HTTP/2 via default Reqwest transport and log negotiated protocol

Cargo.toml

@@ -94,7 +94,9 @@ serde = { version = "1.0", features = ["derive", "alloc"], optional = true, defa
 serde_json = { version = "1.0", optional = true, features = ["alloc"], default-features = false }
 
 # reqwest
-reqwest = { version = "0.12", optional = true }
+# `native-tls-alpn` enables ALPN on the default native-tls backend so HTTP/2
+# (`h2`) can be negotiated; without it reqwest falls back to HTTP/1.1.
+reqwest = { version = "0.12", optional = true, features = ["native-tls-alpn"] }
 bytes = { version = "1.4", default-features = false, optional = true }
 
 # crypto

src/core/retry_policy.rs

@@ -48,9 +48,10 @@ pub enum Endpoint {
 }
 
 /// Request retry policy.
-#[derive(Debug, Clone, PartialEq, Eq)]
+#[derive(Debug, Clone, PartialEq, Eq, Default)]
 pub enum RequestRetryConfiguration {
     /// Requests shouldn't be tried again.
+    #[default]
     None,
 
     /// Retry the request after the same amount of time.
@@ -316,12 +317,6 @@ impl RequestRetryConfiguration {
     }
 }
 
-impl Default for RequestRetryConfiguration {
-    fn default() -> Self {
-        Self::None
-    }
-}
-
 impl From<String> for Endpoint {
     fn from(value: String) -> Self {
         match value.as_str() {

src/transport/reqwest.rs

@@ -6,6 +6,8 @@
 //!
 //! It requires the [`reqwest` feature] to be enabled.
 //!
+//! Negotiates HTTP/2 when the origin supports it; otherwise uses HTTP/1.1.
+//!
 //! [`TransportReqwest`]: ./struct.TransportReqwest.html
 //! [`PubNub API`]: https://www.pubnub.com/docs
 //! [`reqwest`]: https://docs.rs/reqwest
@@ -37,7 +39,7 @@ use crate::{
     PubNubClientBuilder,
 };
 use bytes::Bytes;
-use log::info;
+use log::{debug, info};
 use reqwest::{
     header::{HeaderMap, HeaderName, HeaderValue, InvalidHeaderName, InvalidHeaderValue},
     StatusCode,
@@ -83,6 +85,8 @@ impl Transport for TransportReqwest {
         );
 
         let headers = prepare_headers(&request.headers)?;
+        let method = request.method.clone();
+        let path = request.path.clone();
         #[cfg(feature = "std")]
         let timeout = request.timeout;
 
@@ -116,6 +120,10 @@ impl Transport for TransportReqwest {
 
         let headers = result.headers().clone();
         let status = result.status();
+        debug!(
+            "Request completed: method={method} path={path} protocol={:?}",
+            result.version()
+        );
         result
             .bytes()
             .await
@@ -341,6 +349,8 @@ pub mod blocking {
     //!
     //! It requires the [`reqwest` and `blocking` feature] to be enabled.
     //!
+    //! Negotiates HTTP/2 when the origin supports it; otherwise uses HTTP/1.1.
+    //!
     //! [`TransportReqwest`]: ./struct.TransportReqwest.html
     //! [`PubNub API`]: https://www.pubnub.com/docs
     //! [`reqwest`]: https://docs.rs/reqwest
@@ -368,7 +378,7 @@ pub mod blocking {
         transport::reqwest::{create_result, extract_headers, prepare_headers, prepare_url},
         PubNubClientBuilder,
     };
-    use log::info;
+    use log::{debug, info};
 
     /// This struct is used to send requests to the [`PubNub API`] using the
     /// [`reqwest`] crate. It is used as the transport type for the
@@ -407,6 +417,8 @@ pub mod blocking {
                 request.method, request.headers, request_url
             );
             let headers = prepare_headers(&request.headers)?;
+            let method = request.method.clone();
+            let path = request.path.clone();
             #[cfg(feature = "std")]
             let timeout = request.timeout;
 
@@ -439,6 +451,10 @@ pub mod blocking {
 
             let headers = result.headers().clone();
             let status = result.status();
+            debug!(
+                "Request completed: method={method} path={path} protocol={:?}",
+                result.version()
+            );
             result
                 .bytes()
                 .map_err(|e| PubNubError::Transport {