Home
last modified time | relevance | path

Searched defs:receive (Results 1 – 25 of 67) sorted by relevance

123

/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DNettyHttpClient.java172 void receive(HttpResponse response) { in receive() method in NettyHttpClient.HttpChannel
176 void receive(HttpContent content) { in receive() method in NettyHttpClient.HttpChannel
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DAbstractChannel.kt52 val receive = takeFirstReceiveOrPeekClosed() ?: return OFFER_FAILED in <lambda>() constant
72 val receive = offerOp.result in <lambda>() constant
555 public final override suspend fun receive(): E { in receive() method
571 val receive = if (onUndeliveredElement == null) in receiveSuspend() constant
815 …private inner class RemoveReceiveOnCancel(private val receive: Receive<*>) : BeforeResumeCancelHan… in removeReceiveOnCancel() constant in RemoveReceiveOnCancel
845 val receive = ReceiveHasNext(this, cont) in hasNextSuspend() constant
DConflatedChannel.kt34 var receive: ReceiveOrClosed<E>? = null in offerInternal() variable
62 var receive: ReceiveOrClosed<E>? = null in offerSelectInternal() variable
/external/connectedappssdk/tests/instrumented/src/main/java/com/google/android/enterprise/connectedapps/instrumented/utils/
DBlockingCallbackListener.java35 protected void receive(E value) { in receive() method in BlockingCallbackListener
/external/parameter-framework/asio-1.10.6/include/asio/
Dbasic_stream_socket.hpp439 std::size_t receive(const MutableBufferSequence& buffers) in receive() function in asio::basic_stream_socket
479 std::size_t receive(const MutableBufferSequence& buffers, in receive() function in asio::basic_stream_socket
508 std::size_t receive(const MutableBufferSequence& buffers, in receive() function in asio::basic_stream_socket
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DPing.java37 void receive() { in receive() method in Ping
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DPing.java39 void receive() { in receive() method in Ping
/external/webrtc/test/scenario/
Daudio_stream.h80 ReceiveAudioStream* receive() { return &receive_stream_; } in receive() function
Dvideo_stream.h109 ReceiveVideoStream* receive() { return &receive_stream_; } in receive() function
/external/robolectric-shadows/resources/src/main/java/org/robolectric/res/
DResBunch.java30 void receive(ResourceTable.Visitor visitor) { in receive() method in ResBunch
DResBundle.java21 public void receive(ResourceTable.Visitor visitor) { in receive() method in ResBundle
DResourceTable.java24 void receive(Visitor visitor); in receive() method
/external/okio/okio/jvm/jmh/src/jmh/java/com/squareup/okio/benchmarks/
DBufferPerformanceBenchmark.java242 public BufferedSource receive(byte[] bytes) throws IOException { in receive() method in BufferPerformanceBenchmark.BufferSetup
277 protected Buffer receive(byte[] bytes, int maxChunkSize) throws IOException { in receive() method in BufferPerformanceBenchmark.BufferState
/external/okhttp/okio/benchmarks/src/main/java/com/squareup/okio/benchmarks/
DBufferPerformanceBench.java242 public BufferedSource receive(byte[] bytes) throws IOException { in receive() method in BufferPerformanceBench.BufferSetup
277 protected Buffer receive(byte[] bytes, int maxChunkSize) throws IOException { in receive() method in BufferPerformanceBench.BufferState
/external/perfetto/ui/src/base/
Dremote.ts64 private receive(response: RemoteResponse): void { method in Remote
/external/webrtc/media/base/
Drtp_data_engine.h80 virtual bool SetReceive(bool receive) { in SetReceive()
/external/libchrome/crypto/
Dscoped_capi_types.h68 CAPIHandle* receive() { in receive() function
/external/robolectric-shadows/robolectric/src/main/java/org/robolectric/res/
DNullResourceTable.java52 public void receive(Visitor visitor) { in receive() method in NullResourceTable
/external/skqp/include/private/
DSkMessageBus.h96 void SkMessageBus<Message>::Inbox::receive(const Message& m) { in receive() function
/external/ltp/testcases/open_posix_testsuite/stress/mqueues/
Dmulti_send_rev_2.c56 int *receive(void *ID) in receive() function
Dmulti_send_rev_1.c60 int *receive(void *info) in receive() function
/external/swiftshader/src/System/
DSocket.cpp87 int Socket::receive(char *buffer, int length) in receive() function in sw::Socket
/external/swiftshader/src/Common/
DSocket.cpp86 int Socket::receive(char *buffer, int length) in receive() function in sw::Socket
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DTestChannelKind.kt44 override suspend fun receive(): E = sub.receive() in toString() method
/external/libchrome/base/
Dscoped_generic.h129 element_type* receive() WARN_UNUSED_RESULT { in receive() function

123