Home
last modified time | relevance | path

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

12

/aosp_15_r20/external/grpc-grpc/test/core/transport/
H A 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()
/aosp_15_r20/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
/aosp_15_r20/external/cronet/components/metrics/structured/lib/
H A Dpersistent_proto_internal.cc46 PersistentProtoInternal::ReadCallback on_read, in PersistentProtoInternal()
157 ReadCallback on_read, in UpdatePath()
/aosp_15_r20/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()
/aosp_15_r20/external/grpc-grpc/src/core/lib/event_engine/cf_engine/
H A 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()
H A Dcfstream_endpoint.h114 bool Read(absl::AnyInvocable<void(absl::Status)> on_read, SliceBuffer* buffer, in Read()
/aosp_15_r20/external/grpc-grpc/test/core/transport/chaotic_good/
H A 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()
H A Dmock_promise_endpoint.cc41 grpc_event_engine::experimental::SliceBuffer* buffer) mutable { in ExpectRead()
/aosp_15_r20/external/grpc-grpc/src/core/lib/iomgr/
H A Dtcp_windows.cc109 grpc_closure on_read; member
177 static void on_read(void* tcpp, grpc_error_handle error) { in on_read() function
/aosp_15_r20/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
/aosp_15_r20/external/grpc-grpc/src/core/lib/security/transport/
H A Dsecure_endpoint.cc129 grpc_closure on_read; member
251 static void on_read(void* user_data, grpc_error_handle error) { in on_read() function
/aosp_15_r20/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
/aosp_15_r20/external/grpc-grpc/test/core/event_engine/windows/
H A Dwin_socket_test.cc68 AnyInvocableClosure on_read([&read_called]() { read_called.Notify(); }); in TEST_F() local
H A Diocp_test.cc69 AnyInvocableClosure* on_read; in TEST_F() local
/aosp_15_r20/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()
/aosp_15_r20/external/grpc-grpc/src/core/lib/event_engine/windows/
H A Dwin_socket.cc100 void WinSocket::NotifyOnRead(EventEngine::Closure* on_read) { in NotifyOnRead()
H A Dwindows_endpoint.cc129 bool WindowsEndpoint::Read(absl::AnyInvocable<void(absl::Status)> on_read, in Read()
/aosp_15_r20/external/grpc-grpc/test/core/event_engine/fuzzing_event_engine/
H A Dfuzzing_event_engine.h186 absl::AnyInvocable<void(absl::Status)> on_read; member
/aosp_15_r20/external/grpc-grpc/test/core/util/
H A Dmock_endpoint.cc42 grpc_closure* on_read; member
/aosp_15_r20/external/grpc-grpc/test/core/end2end/
H A Dbad_server_response_test.cc105 static grpc_closure on_read; variable
/aosp_15_r20/external/grpc-grpc/test/core/event_engine/test_suite/posix/
H A Doracle_event_engine_posix.cc233 bool PosixOracleEndpoint::Read(absl::AnyInvocable<void(absl::Status)> on_read, in Read()
/aosp_15_r20/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()
/aosp_15_r20/external/grpc-grpc/src/core/lib/event_engine/posix_engine/
H A Dposix_endpoint.h616 absl::AnyInvocable<void(absl::Status)> on_read, in Read()

12