Home
last modified time | relevance | path

Searched refs:flush (Results 1 – 12 of 12) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
Dssl_stream.rs49 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/
Dasync_buf_writer.rs173 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/
Dstream.rs200 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/
Djs_textdecoder.cpp74 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/
Dstream.rs250 fn flush(&mut self) -> io::Result<()> {
251 self.state.try_io(|mut inner| inner.flush(), &self.inner)
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dasync_buf_write.rs52 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/
Dstream.rs212 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/
Dwrapper.rs68 fn flush(&mut self) -> io::Result<()> { in flush() function
Dc_ssl_stream.rs122 self.with_context(ctx, |s| check_io_to_poll(s.flush())) in poll_flush()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
Dasync_write.rs274 fn flush(&mut self) -> FlushTask<'_, Self> in flush() method
Dstdio.rs168 let res = inner.flush().map(|_| 0);
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
Dbio.rs192 match catch_unwind(AssertUnwindSafe(|| state.stream.flush())) { in ctrl()