Home
last modified time | relevance | path

Searched defs:on_read (Results 1 – 25 of 36) sorted by relevance

12

/external/cronet/tot/components/metrics/structured/lib/
Dpersistent_proto_internal.cc45 PersistentProtoInternal::ReadCallback on_read, in PersistentProtoInternal()
164 ReadCallback on_read, in UpdatePath()
/external/cronet/stable/components/metrics/structured/lib/
Dpersistent_proto_internal.cc45 PersistentProtoInternal::ReadCallback on_read, in PersistentProtoInternal()
164 ReadCallback on_read, in UpdatePath()
/external/python/bumble/bumble/profiles/
Daics.py157 def on_read(self, _connection: Optional[Connection]) -> bytes: member in AudioInputState
189 def on_read(self, _connection: Optional[Connection]) -> bytes: member in GainSettingsProperties
331 def on_read(self, _connection: Optional[Connection]) -> bytes: member in AudioInputDescription
/external/grpc-grpc/test/core/transport/
Dpromise_endpoint_test.cc224 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
251 [&read_callback](absl::AnyInvocable<void(absl::Status)> on_read) { in TEST_F()
361 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
388 [&read_callback](absl::AnyInvocable<void(absl::Status)> on_read) { in TEST_F()
479 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
506 [&read_callback](absl::AnyInvocable<void(absl::Status)> on_read) { in TEST_F()
649 grpc_event_engine::experimental::SliceBuffer* buffer) { in TEST_F()
/external/grpc-grpc/test/core/transport/chaotic_good/
Dmock_promise_endpoint.cc41 grpc_event_engine::experimental::SliceBuffer* buffer) mutable { in ExpectRead()
Dclient_transport_error_test.cc218 [](absl::AnyInvocable<void(absl::Status)> on_read) mutable { in TEST_F()
344 [](absl::AnyInvocable<void(absl::Status)> on_read) mutable { in TEST_F()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/cf_engine/
Dcfstream_endpoint.cc254 absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
274 absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer) { in DoRead()
Dcfstream_endpoint.h112 bool Read(absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
/external/grpc-grpc/src/core/lib/event_engine/cf_engine/
Dcfstream_endpoint.cc260 absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
280 absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer) { in DoRead()
Dcfstream_endpoint.h114 bool Read(absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
/external/grpc-grpc/test/core/event_engine/windows/
Dwin_socket_test.cc68 AnyInvocableClosure on_read([&read_called]() { read_called.Notify(); }); in TEST_F() local
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/windows/
Dwin_socket.cc104 void WinSocket::NotifyOnRead(EventEngine::Closure* on_read) { in NotifyOnRead()
Dwindows_endpoint.cc127 bool WindowsEndpoint::Read(absl::AnyInvocable<void(absl::Status)> on_read, in Read()
/external/grpc-grpc/src/core/lib/event_engine/windows/
Dwin_socket.cc100 void WinSocket::NotifyOnRead(EventEngine::Closure* on_read) { in NotifyOnRead()
Dwindows_endpoint.cc129 bool WindowsEndpoint::Read(absl::AnyInvocable<void(absl::Status)> on_read, in Read()
/external/grpc-grpc/test/core/event_engine/fuzzing_event_engine/
Dfuzzing_event_engine.h186 absl::AnyInvocable<void(absl::Status)> on_read; member
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dtcp_windows.cc109 grpc_closure on_read; member
177 static void on_read(void* tcpp, grpc_error_handle error) { in on_read() function
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_windows.cc109 grpc_closure on_read; member
177 static void on_read(void* tcpp, grpc_error_handle error) { in on_read() function
/external/grpc-grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc129 grpc_closure on_read; member
251 static void on_read(void* user_data, grpc_error_handle error) { in on_read() function
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc132 grpc_closure on_read; member
254 static void on_read(void* user_data, grpc_error_handle error) { in on_read() function
/external/grpc-grpc/test/core/util/
Dmock_endpoint.cc42 grpc_closure* on_read; member
/external/grpc-grpc/test/core/end2end/
Dbad_server_response_test.cc105 static grpc_closure on_read; variable
/external/grpc-grpc/test/core/event_engine/test_suite/posix/
Doracle_event_engine_posix.cc233 bool PosixOracleEndpoint::Read(absl::AnyInvocable<void(absl::Status)> on_read, in Read()
/external/grpc-grpc/src/core/lib/event_engine/posix_engine/
Dposix_endpoint.h616 absl::AnyInvocable<void(absl::Status)> on_read, in Read()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/posix_engine/
Dposix_endpoint.h614 absl::AnyInvocable<void(absl::Status)> on_read, in Read()

12