| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/neqo-http3/src/ |
| H A D | response_stream.rs | 147 ResponseHeadersState::Read => self.conn_events.data_readable(self.stream_id), in set_state_to_close_pending()
280 self.conn_events.data_readable(self.stream_id); in receive()
|
| H A D | client_events.rs | 55 pub fn data_readable(&self, stream_id: u64) { in data_readable() method
|
| H A D | connection_client.rs | 3019 let data_readable: fn(&Http3ClientEvent) -> _ = in test_trailers_with_fin_after_headers() localVariable
3021 assert!(events.iter().any(data_readable)); in test_trailers_with_fin_after_headers()
3065 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_trailers_with_later_fin_after_headers() localVariable
3066 assert!(!client.events().any(data_readable)); in test_trailers_with_later_fin_after_headers()
3081 let data_readable: fn(&Http3ClientEvent) -> _ = in test_trailers_with_later_fin_after_headers() localVariable
3083 assert!(events.iter().any(data_readable)); in test_trailers_with_later_fin_after_headers()
3126 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_data_after_trailers_after_headers() localVariable
3127 assert!(!client.events().any(data_readable)); in test_data_after_trailers_after_headers()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/neqo-http3/src/ |
| H A D | server_connection_events.rs | 51 fn data_readable(&self, stream_id: u64) { in data_readable() method
|
| H A D | recv_message.rs | 192 self.conn_events.data_readable(self.stream_id) in set_state_to_close_pending()
309 self.conn_events.data_readable(self.stream_id); in receive_internal()
|
| H A D | client_events.rs | 98 fn data_readable(&self, stream_id: u64) { in data_readable() method
|
| H A D | lib.rs | 337 fn data_readable(&self, stream_id: u64); in data_readable() method
|
| H A D | push_controller.rs | 478 fn data_readable(&self, _stream_id: u64) { in data_readable() method
|
| H A D | connection_client.rs | 4023 let data_readable: fn(&Http3ClientEvent) -> _ = in test_trailers_with_fin_after_headers() localVariable
4025 assert!(events.iter().any(data_readable)); in test_trailers_with_fin_after_headers()
4077 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_trailers_with_later_fin_after_headers() localVariable
4078 assert!(!client.events().any(data_readable)); in test_trailers_with_later_fin_after_headers()
4147 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_data_after_trailers_after_headers() localVariable
4148 assert!(!client.events().any(data_readable)); in test_data_after_trailers_after_headers()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/neqo-http3/src/ |
| H A D | server_connection_events.rs | 51 fn data_readable(&self, stream_id: u64) { in data_readable() method
|
| H A D | recv_message.rs | 192 self.conn_events.data_readable(self.stream_id) in set_state_to_close_pending()
309 self.conn_events.data_readable(self.stream_id); in receive_internal()
|
| H A D | client_events.rs | 98 fn data_readable(&self, stream_id: u64) { in data_readable() method
|
| H A D | lib.rs | 337 fn data_readable(&self, stream_id: u64); in data_readable() method
|
| H A D | push_controller.rs | 478 fn data_readable(&self, _stream_id: u64) { in data_readable() method
|
| H A D | connection_client.rs | 4023 let data_readable: fn(&Http3ClientEvent) -> _ = in test_trailers_with_fin_after_headers() localVariable
4025 assert!(events.iter().any(data_readable)); in test_trailers_with_fin_after_headers()
4077 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_trailers_with_later_fin_after_headers() localVariable
4078 assert!(!client.events().any(data_readable)); in test_trailers_with_later_fin_after_headers()
4147 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_data_after_trailers_after_headers() localVariable
4148 assert!(!client.events().any(data_readable)); in test_data_after_trailers_after_headers()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/neqo-http3/src/ |
| H A D | recv_message.rs | 220 self.conn_events.data_readable(self.get_stream_info()); in set_state_to_close_pending()
343 self.conn_events.data_readable(self.get_stream_info()); in receive_internal()
|
| H A D | server_connection_events.rs | 82 fn data_readable(&self, stream_info: Http3StreamInfo) { in data_readable() method
|
| H A D | client_events.rs | 111 fn data_readable(&self, stream_info: Http3StreamInfo) { in data_readable() method
|
| H A D | lib.rs | 411 fn data_readable(&self, _stream_info: Http3StreamInfo) {} in data_readable() method
|
| H A D | push_controller.rs | 470 fn data_readable(&self, _stream_info: Http3StreamInfo) { in data_readable() method
|
| H A D | connection_client.rs | 4199 let data_readable: fn(&Http3ClientEvent) -> _ = in test_trailers_with_fin_after_headers() localVariable
4201 assert!(events.iter().any(data_readable)); in test_trailers_with_fin_after_headers()
4253 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_trailers_with_later_fin_after_headers() localVariable
4254 assert!(!client.events().any(data_readable)); in test_trailers_with_later_fin_after_headers()
4323 let data_readable = |e| matches!(e, Http3ClientEvent::DataReadable { .. }); in test_data_after_trailers_after_headers() localVariable
4324 assert!(!client.events().any(data_readable)); in test_data_after_trailers_after_headers()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/neqo-http3/src/features/extended_connect/ |
| H A D | webtransport_streams.rs | 58 self.events.data_readable(self.get_info()); in receive()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/netwerk/protocol/http/ |
| H A D | Http3Session.cpp | 308 id = event.data_readable.stream_id; in ProcessEvents()
|
| /dports/www/firefox-esr/firefox-91.8.0/netwerk/protocol/http/ |
| H A D | Http3Session.cpp | 394 uint64_t id = event.data_readable.stream_id; in ProcessEvents()
|
| /dports/www/firefox/firefox-99.0/netwerk/protocol/http/ |
| H A D | Http3Session.cpp | 399 uint64_t id = event.data_readable.stream_id; in ProcessEvents()
|