Searched refs:Empty (Results 1 - 13 of 13) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | request.rs | 240 /// - Empty: an empty body.
257 Empty,
274 Body::new(BodyKind::Empty) in empty()
346 BodyKind::Empty => Ok(()),
365 BodyKind::Empty => Poll::Ready(Ok(())), in poll_read()
|
| H A D | http_body.rs | 80 BodyLength::Empty => {
86 Kind::Empty
121 Kind::Empty => Poll::Ready(Ok(0)), in poll_data()
181 Empty,
757 BodyLength::Empty, in http_body_empty_err()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | error.rs | 67 Empty,
75 TryRecvError::Empty => write!(f, "channel is empty"), in fmt()
140 let try_recv_err1 = TryRecvError::Empty; in ut_test_sync_error_display()
|
| H A D | oneshot.rs | 283 /// * `Err(TryRecvError::Empty)` if no value has been sent yet.
297 /// Err(TryRecvError::Empty) => {}
328 INIT => Err(TryRecvError::Empty), in try_recv()
478 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in fmt()
|
| H A D | semaphore_inner.rs | 49 Empty,
58 SemaphoreError::Empty => write!(f, "no permits available"), in fmt()
125 return Err(SemaphoreError::Empty);
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_queue_benchmark_test/ |
| H A D | safe_queue_benchmark_test.cpp | 94 void Empty() in Empty() function in OHOS::__anon22::DemoThreadData
96 shareQueue.Empty(); in Empty()
132 q.Empty(); in EmptyHandleThreadDataTime()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 56 Self { kind: Kind::Empty }
74 Empty,
104 Kind::Empty => Ok(0), in data()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | mpsc_test.rs | 69 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in sdv_unbounded_send_try_recv_test()
150 assert_eq!(rx.try_recv(), Err(TryRecvError::Empty)); in sdv_bounded_try_send_try_recv_test()
|
| /commonlibrary/c_utils/base/include/ |
| H A D | safe_queue.h | 62 bool Empty() in Empty() function in OHOS::SafeQueueInner
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | array.rs | 163 Err(TryRecvError::Empty)
172 Err(TryRecvError::Empty) => {}
180 Err(TryRecvError::Empty) => Pending,
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_safe_queue_test.cpp | 308 ASSERT_FALSE(DemoThreadData::shareQueue.Empty()); in HWTEST_F()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | queue.rs | 214 Err(TryRecvError::Empty)
231 Err(TryRecvError::Empty) => Pending,
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_dir.rs | 525 Empty(JoinHandle<Entries>),
573 self.0 = State::Empty(spawn_blocking(&TaskBuilder::new(), move || { in poll_next()
578 State::Empty(ref mut handle) => { in poll_next()
|
Completed in 8 milliseconds