Home
last modified time | relevance | path

Searched refs:peek (Results 1 - 10 of 10) sorted by relevance

/commonlibrary/rust/ylong_json/src/reader/
H A Dio_reader.rs28 /// let char = io_reader.peek();
143 fn peek(&mut self) -> Result<Option<u8>> { in peek() functions
350 /// UT test case for `IoReader::peek`.
357 /// 2. Call `IoReader::peek`.
366 assert_eq!(io_reader.peek().unwrap(), Some(1)); in ut_io_reader_peek()
367 assert_eq!(io_reader.peek().unwrap(), Some(1)); in ut_io_reader_peek()
369 assert_eq!(io_reader.peek().unwrap(), None); in ut_io_reader_peek()
374 assert_eq!(io_reader.peek().unwrap(), None); in ut_io_reader_peek()
380 assert!(io_reader.peek().is_err()); in ut_io_reader_peek()
453 // Use `peek()` an in ut_io_reader_position()
[all...]
H A Dmod.rs21 /// `peek`, `index`. Users can obtain the next byte or the current read
32 fn peek(&mut self) -> Result<Option<u8>, Self::Error>; in peek() functions
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dstream.rs199 /// Same as std::net::TcpStream::peek().
213 /// let len = stream.peek(&mut buf).expect("peek failed");
215 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek() functions
216 self.inner.peek(buf) in peek()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
H A Dstream.rs241 /// Same as std::net::TcpStream::peek().
255 /// let len = stream.peek(&mut buf).expect("peek failed");
257 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek() functions
258 self.inner.peek(buf) in peek()
/commonlibrary/rust/ylong_json/src/
H A Dstates.rs44 match $deserializer.reader.peek().map_err(Error::new_reader)? {
55 match $deserializer.reader.peek().map_err(Error::new_reader)? {
66 match $deserializer.reader.peek().map_err(Error::new_reader)? {
233 match deserializer.reader.peek().map_err(Error::new_reader)? {
275 match deserializer.reader.peek().map_err(Error::new_reader)? { in parse_escape_character()
304 if let Some(ch) = deserializer.reader.peek().map_err(Error::new_reader)? { in parse_unicode()
364 if let Some(MINUS) = deserializer.reader.peek().map_err(Error::new_reader)? {
368 // `next_ch` temporarily saves unmatched characters after peek.
370 let mut next_ch = match deserializer.reader.peek().map_err(Error::new_reader)? {
375 // The reason to peek her
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dstream.rs523 /// let len = stream.peek(&mut buf).await.expect("peek failed"); in fmt()
527 pub async fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in fmt()
529 .async_process(Interest::READABLE, || self.source.peek(buf)) in fmt()
720 /// 3. Call peek() to get.
735 let len = stream.peek(&mut buf).await.expect("peek failed"); in ut_tcp_stream_peek()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/
H A Dudp_socket.rs596 /// match connect_socket.peek(&mut buf) {
598 /// Err(e) => println!("peek function failed: {e:?}"),
601 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek() functions
603 inner.peek(buf) in peek()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/
H A Dudp_socket.rs477 /// match connect_socket.peek(&mut buf) {
479 /// Err(e) => println!("peek function failed: {e:?}"),
482 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek() functions
483 self.state.try_io(|inner| inner.peek(buf), &self.inner) in peek()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dudp.rs1204 /// match connect_socket.peek(&mut buf).await {
1206 /// Err(e) => println!("peek function failed: {e:?}"),
1211 pub async fn peek(&self, buf: &mut [u8]) -> io::Result<usize> {
1213 .async_process(Interest::READABLE, || self.source.peek(buf))
1246 .try_io(Interest::READABLE, || self.source.peek(buf)) in try_peek()
1824 /// UT test cases for `peek()` in ConnectedUdpSocket.
1830 /// 4. ConnectedUdpSocket calls peek() to receive message.
1851 .peek(&mut buf) in ut_connected_peek()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtcp_test.rs159 /// 3. Call peek() to get.
175 let len = stream.peek(&mut buf).await.expect("peek failed!"); in sdv_tcp_stream_peek()

Completed in 9 milliseconds