summaryrefslogtreecommitdiff
path: root/ext/http/request_properties.rs
diff options
context:
space:
mode:
authorMatt Mastracci <matthew@mastracci.com>2024-04-08 16:18:14 -0600
committerGitHub <noreply@github.com>2024-04-08 16:18:14 -0600
commit47061a4539feab411fbbd7db5604f4bd4a532051 (patch)
tree5f6f17066b6f967b1504ef9b762288ad670d1389 /ext/http/request_properties.rs
parent6157c8563484e53b1917c811e94e4b5afa01dc67 (diff)
feat(ext/net): Refactor TCP socket listeners for future clustering mode (#23037)
Changes: - Implements a TCP socket listener that will allow for round-robin load-balancing in-process. - Cleans up the raw networking code to make it easier to work with.
Diffstat (limited to 'ext/http/request_properties.rs')
-rw-r--r--ext/http/request_properties.rs6
1 files changed, 5 insertions, 1 deletions
diff --git a/ext/http/request_properties.rs b/ext/http/request_properties.rs
index 02ef13871..1422c7417 100644
--- a/ext/http/request_properties.rs
+++ b/ext/http/request_properties.rs
@@ -119,7 +119,11 @@ impl HttpPropertyExtractor for DefaultHttpPropertyExtractor {
async fn accept_connection_from_listener(
listener: &NetworkStreamListener,
) -> Result<NetworkStream, AnyError> {
- listener.accept().await.map_err(Into::into)
+ listener
+ .accept()
+ .await
+ .map_err(Into::into)
+ .map(|(stm, _)| stm)
}
fn listen_properties_from_listener(