Searched refs:flush (Results 1 – 12 of 12) sorted by relevance
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
D | ssl_stream.rs | 49 fn flush(&mut self) -> std::io::Result<()> { in flush() function 51 MixStream::Http(s) => s.flush(), in flush() 52 MixStream::Https(s) => s.flush(), in flush()
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
D | async_buf_writer.rs | 173 fn flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in flush() method 212 poll_ready!(self.as_mut().flush(cx))?; in poll_write() 235 poll_ready!(self.as_mut().flush(cx))?; in poll_write_vectored() 256 poll_ready!(self.as_mut().flush(cx))?; in poll_write_vectored() 283 poll_ready!(self.as_mut().flush(cx))?; in poll_flush() 289 poll_ready!(self.as_mut().flush(cx))?; in poll_shutdown() 301 poll_ready!(self.as_mut().flush(cx))?; in poll_seek()
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/tcp/ |
D | stream.rs | 200 fn flush(&mut self) -> io::Result<()> { in flush() method 201 self.inner.flush() in flush() 228 fn flush(&mut self) -> io::Result<()> { in flush() method 230 inner.flush() in flush()
|
/commonlibrary/ets_utils/js_util_module/util/ |
D | js_textdecoder.cpp | 74 UBool flush = ((flags & static_cast<uint8_t>(ConverterFlags::FLUSH_FLG))) == in Decode() local 100 …ode(GetConverterPtr(), &target, target + len, &source, source + length, nullptr, flush, &codeFlag); in Decode() 113 if (flush) { in Decode()
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
D | stream.rs | 250 fn flush(&mut self) -> io::Result<()> { 251 self.state.try_io(|mut inner| inner.flush(), &self.inner)
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
D | async_buf_write.rs | 52 buf_writer.flush().await.unwrap(); in sdv_buf_writer_write() 94 buf_writer.flush().await.unwrap(); in sdv_buf_writer_write_vectored()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
D | stream.rs | 212 fn flush(&mut self) -> io::Result<()> { in flush() method 213 self.get_mut().flush() in flush()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
D | wrapper.rs | 68 fn flush(&mut self) -> io::Result<()> { in flush() function
|
D | c_ssl_stream.rs | 122 self.with_context(ctx, |s| check_io_to_poll(s.flush())) in poll_flush()
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
D | async_write.rs | 274 fn flush(&mut self) -> FlushTask<'_, Self> in flush() method
|
D | stdio.rs | 168 let res = inner.flush().map(|_| 0);
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
D | bio.rs | 192 match catch_unwind(AssertUnwindSafe(|| state.stream.flush())) { in ctrl()
|