@@ -954,7 +954,7 @@ PicoQuicTransport::CreateDataContextBiDirRecv(TransportConnId conn_id, uint64_t
954
954
data_ctx_it->second .current_stream_id = stream_id;
955
955
956
956
#if __cplusplus >= 202002L
957
- cbNotifyQueue_.push ([=, data_ctx_id = data_ctx_it->second .data_ctx_id , this ]() {
957
+ cbNotifyQueue_.Push ([=, data_ctx_id = data_ctx_it->second .data_ctx_id , this ]() {
958
958
#else
959
959
cbNotifyQueue_.Push ([=, data_ctx_id = data_ctx_it->second .data_ctx_id ]() {
960
960
#endif
@@ -1311,7 +1311,7 @@ PicoQuicTransport::OnConnectionStatus(const TransportConnId conn_id, const Trans
1311
1311
}
1312
1312
1313
1313
#if __cplusplus >= 202002L
1314
- _cbNotifyQueue. push ([=, this ]() { _delegate. on_connection_status (conn_id, status); });
1314
+ cbNotifyQueue_. Push ([=, this ]() { delegate_. OnConnectionStatus (conn_id, status); });
1315
1315
#else
1316
1316
cbNotifyQueue_.Push ([=]() { delegate_.OnConnectionStatus (conn_id, status); });
1317
1317
#endif
@@ -1344,7 +1344,7 @@ PicoQuicTransport::OnNewConnection(const TransportConnId conn_id)
1344
1344
}
1345
1345
1346
1346
#if __cplusplus >= 202002L
1347
- _cbNotifyQueue. push ([=, this ]() { _delegate. on_new_connection (conn_id, remote); });
1347
+ cbNotifyQueue_. Push ([=, this ]() { delegate_. OnNewConnection (conn_id, remote); });
1348
1348
#else
1349
1349
cbNotifyQueue_.Push ([=]() { delegate_.OnNewConnection (conn_id, remote); });
1350
1350
#endif
@@ -1371,7 +1371,7 @@ PicoQuicTransport::OnRecvDatagram(ConnectionContext* conn_ctx, uint8_t* bytes, s
1371
1371
}
1372
1372
1373
1373
#if __cplusplus >= 202002L
1374
- if (conn_ctx->dgram_rx_data ->Size () < 10 && !_cbNotifyQueue .Push ([=, this ]() {
1374
+ if (conn_ctx->dgram_rx_data ->Size () < 10 && !cbNotifyQueue_ .Push ([=, this ]() {
1375
1375
#else
1376
1376
if (conn_ctx->dgram_rx_data ->Size () < 10 && !cbNotifyQueue_.Push ([=]() {
1377
1377
#endif
@@ -1416,7 +1416,7 @@ PicoQuicTransport::OnRecvStreamBytes(ConnectionContext* conn_ctx,
1416
1416
data_ctx->metrics .rx_stream_bytes += bytes.size ();
1417
1417
1418
1418
#if __cplusplus >= 202002L
1419
- if (!_cbNotifyQueue. push ([=, this ]() {
1419
+ if (!cbNotifyQueue_. Push ([=, this ]() {
1420
1420
#else
1421
1421
if (!cbNotifyQueue_.Push ([=]() {
1422
1422
#endif
@@ -1429,7 +1429,7 @@ PicoQuicTransport::OnRecvStreamBytes(ConnectionContext* conn_ctx,
1429
1429
1430
1430
} else {
1431
1431
#if __cplusplus >= 202002L
1432
- if (!_cbNotifyQueue. push ([=, this ]() {
1432
+ if (!cbNotifyQueue_. Push ([=, this ]() {
1433
1433
#else
1434
1434
if (!cbNotifyQueue_.Push ([=]() {
1435
1435
#endif
0 commit comments