Skip to content

Commit 31268c9

Browse files
fix(s2n-quic-dc): Wire event_subscriber into s2n-quic endpoints (#3054)
1 parent f9f2953 commit 31268c9

3 files changed

Lines changed: 3 additions & 5 deletions

File tree

dc/s2n-quic-dc/src/psk/client/builder.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ use super::Provider;
1919
pub struct Builder<
2020
Event: s2n_quic::provider::event::Subscriber = s2n_quic::provider::event::default::Subscriber,
2121
> {
22-
#[allow(dead_code)]
2322
pub(crate) event_subscriber: Event,
2423
pub(crate) data_window: u64,
2524
pub(crate) mtu: u16,

dc/s2n-quic-dc/src/psk/io.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ impl Server {
9191
let server = server
9292
.with_limits(connection_limits)?
9393
.with_dc(map.clone())?
94-
.with_event(event)?
94+
.with_event((event, builder.event_subscriber))?
9595
.with_tls(tls_materials_provider)?;
9696
if let Some(limiter) = builder.endpoint_limits {
9797
server.with_endpoint_limits(limiter)?.start()?
@@ -103,7 +103,7 @@ impl Server {
103103
let server = server
104104
.with_limits(connection_limits)?
105105
.with_dc(map.clone())?
106-
.with_event(event)?
106+
.with_event((event, builder.event_subscriber))?
107107
.with_tls(tls_materials_provider)?
108108
.start()?;
109109
}
@@ -221,7 +221,7 @@ impl Client {
221221
let client = client
222222
.with_limits(connection_limits)?
223223
.with_dc(map.clone())?
224-
.with_event(event)?
224+
.with_event((event, builder.event_subscriber))?
225225
.with_tls(tls_materials_provider)?
226226
.start()?;
227227

dc/s2n-quic-dc/src/psk/server/builder.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@ use super::Provider;
1515
pub struct Builder<
1616
Event: s2n_quic::provider::event::Subscriber = s2n_quic::provider::event::default::Subscriber,
1717
> {
18-
#[allow(dead_code)]
1918
pub(crate) event_subscriber: Event,
2019
pub(crate) data_window: u64,
2120
pub(crate) initial_data_window: Option<u64>,

0 commit comments

Comments
 (0)