/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
H A D | ssl_stream.rs | 14 use std::io::{Read, Write}; 27 impl<T> Read for MixStream<T> 29 T: Read + Write, 40 T: Read + Write,
|
H A D | connector.rs | 14 use std::io::{Read, Write}; 24 type Stream: Read + Write + 'static; 78 use std::io::{Read, Write};
|
H A D | pool.rs | 15 use std::io::{Read, Write}; 71 impl<S: Read + Write + 'static> Conns<S> {
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
H A D | mod.rs | 14 use std::io::{Read, Write}; 24 pub(crate) trait StreamData: Read { 34 S: Read + Write + 'static,
|
H A D | http1.rs | 14 use std::io::{Read, Write}; 34 S: Read + Write + 'static, 125 impl<S: Read> Read for Http1Conn<S> { 131 impl<S: Read> StreamData for Http1Conn<S> {
|
/commonlibrary/c_utils/base/src/ |
H A D | parcel.cpp | 167 UTILS_LOGE("Non-object Read object data, readPos = %{public}zu, upperBound = %{public}zu", readCursor_, upperBound); in IsReadObjectData() 774 bool Parcel::Read(T &value) in Read() function in OHOS::Parcel 796 T Parcel::Read() in Read() function in OHOS::Parcel 799 return Read<T>(lvalue) ? lvalue : 0; in Read() 943 int32_t temp = Read<int32_t>(); in ReadBool() 949 return Read<bool>(); in ReadBoolUnaligned() 954 int32_t temp = Read<int32_t>(); in ReadInt8() 960 int32_t temp = Read<int32_t>(); in ReadInt16() 966 return Read<int32_t>(); in ReadInt32() 971 return Read<int64_ in ReadInt64() [all...] |
/commonlibrary/rust/ylong_http/ylong_http/src/body/ |
H A D | mod.rs | 61 use std::io::Read; 81 /// // Read 4 bytes. `buf` is filled. 87 /// // Read next 1 bytes. Part of `buf` is filled. 138 /// // Read 4 bytes. `buf` is filled. 144 /// // Read next 1 bytes. Part of `buf` is filled. 164 impl<T: Read> Body for T { 201 /// // Read 4 bytes. `buf` is filled. 207 /// // Read next 1 bytes. Part of `buf` is filled. 271 /// // Read 4 bytes. `buf` is filled. 277 /// // Read nex [all...] |
H A D | text.rs | 17 use std::io::{Error, Read}; 29 /// # Read From Memory 45 /// # Read From Reader 61 /// # Read From Async Reader 79 /// # Read Body Content 149 impl<T: Read> TextBody<FromReader<T>> { 188 Read::read(&mut *self.from, buf) in data() 200 Poll::Ready(Read::read(&mut *self.from, buf)) in poll_data() 204 impl<T: Read> sync_impl::Body for TextBody<FromReader<T>> {
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
H A D | output.rs | 35 Read, 71 state: DecodeState::Read, 72 next_state: DecodeState::Read, 83 DecodeState::Read => { 106 self.next_state = DecodeState::Read; 116 self.next_state = DecodeState::Read; 128 self.next_state = DecodeState::Read;
|
/commonlibrary/rust/ylong_json/src/reader/ |
H A D | io_reader.rs | 15 use std::io::{Error, ErrorKind, Read, Result}; 30 pub(crate) struct IoReader<R: Read> { 55 impl<R: Read> IoReader<R> { 117 impl<R: Read> BytesReader for IoReader<R> { 187 impl<R: Read> Cacheable for IoReader<R> { 228 use std::io::{ErrorKind, Read}; 241 impl Read for TestIo { 268 impl Read for TestWouldBlockIo { 286 impl Read for TestErrIo {
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
H A D | stream.rs | 14 use std::io::{self, IoSlice, IoSliceMut, Read, Write}; 220 impl Read for TcpStream { 244 impl Read for &TcpStream { impls
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
H A D | stream.rs | 15 use std::io::{self, IoSlice, IoSliceMut, Read, Write}; 162 impl Read for UnixStream { 185 impl Read for &UnixStream { impls
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
H A D | bio.rs | 18 use std::io::{self, Read, Write}; 84 fn new<S: Read + Write>() -> Result<BioMethodInner, ErrorStack> { in new() 118 fn new<S: Read + Write>() -> Result<BioMethod, ErrorStack> { in new() 157 pub(crate) fn new<S: Read + Write>(stream: S) -> Result<(*mut BIO, BioMethod), ErrorStack> { 264 unsafe extern "C" fn bread<S: Read>(bio: *mut BIO, buf: *mut c_char, len: c_int) -> c_int {
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
H A D | wrapper.rs | 17 use std::io::{self, Read, Write}; 42 impl<S> Read for Wrapper<S>
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
H A D | file_buf.rs | 15 use std::io::{Read, Write}; 67 pub(crate) fn read<R: Read>(&mut self, io: &mut R) -> io::Result<usize> {
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
H A D | ssl_base.rs | 17 use std::io::{Read, Write}; 69 S: Read + Write,
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
H A D | stdio.rs | 14 use std::io::{Read, Write}; 86 pub(crate) fn read_from<T: Read>(&mut self, std: &mut T) -> io::Result<usize> {
|
/commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
H A D | ylong_io_tcp_client.rs | 18 use std::io::{Read, Write};
|
H A D | ylong_io_tcp_server.rs | 20 use std::io::{Read, Write};
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
H A D | sys.rs | 17 use std::io::{Read, Write}; 121 impl Read for $type { impls 209 use std::io::{Read, Write};
|
/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
H A D | octets.rs | 15 use std::io::Read;
|
/commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
H A D | async_certs_adapter.rs | 16 use std::io::Read;
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
H A D | driver.rs | 14 use std::io::{ErrorKind, Read};
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
H A D | waker.rs | 38 use std::io::{Read, Write};
|
/commonlibrary/c_utils/base/include/ |
H A D | parcel.h | 517 * @brief Read a block of data (buffer data) from this parcel. 748 * @param Write Indicates the `Parcel::Read(T2 value)` method. 753 bool ReadVector(std::vector<T> *val, bool (Parcel::*Read)(T &)); 811 bool Read(T &value); 814 T Read(); 878 // Read data from the given parcel into this parcelable object. 889 // Read data from the given parcel into this parcelable object, and return sptr.
|