Searched refs:writer (Results 1 - 7 of 7) sorted by relevance
| /commonlibrary/rust/ylong_json/src/ |
| H A D | encoder.rs | 257 fn encode_null(writer: &mut dyn Write) -> Result<(), Error> { in encode_null()
258 writer.write_all(NULL_STR)?; in encode_null()
263 fn encode_boolean(writer: &mut dyn Write, boolean: bool) -> Result<(), Error> { in encode_boolean()
265 writer.write_all(TRUE_STR)?; in encode_boolean()
267 writer.write_all(FALSE_STR)?; in encode_boolean()
273 pub(crate) fn encode_number(writer: &mut dyn Write, number: &Number) -> Result<(), Error> {
274 write!(writer, "{number}")?;
279 fn encode_string(writer: &mut dyn Write, string: &str) -> Result<(), Error> { in encode_string()
280 writer.write_all(QUOTATION_MARK_STR)?; in encode_string()
281 encode_string_inner(writer, strin in encode_string()
399 let mut writer = StringWriter::new(); global() variables
[all...] |
| H A D | serializer_compact.rs | 23 writer: W,
50 let mut writer = AuxiliaryWriter { output: Vec::new() }; in to_string() variables
51 to_writer(value, &mut writer)?; in to_string()
52 Ok(unsafe { String::from_utf8_unchecked(writer.output) }) in to_string()
56 /// writes result into the writer passed in by the user, which needs to implement the std::io::Write.
57 pub fn to_writer<T, W>(value: &T, writer: &mut W) -> Result<(), Error> in to_writer()
63 writer, in to_writer()
93 self.writer.write_fmt(format_args!("{v}"))?; in serialize_bool()
113 self.writer.write_fmt(format_args!("{v}"))?; in serialize_i64()
130 self.writer in serialize_u64()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | write_task.rs | 24 match $self.writer.take() {
25 Some(writer) => writer,
35 writer: Option<&'a mut W>,
44 pub(crate) fn new(writer: &'a mut W, buf: &'a [u8]) -> WriteTask<'a, W> {
46 writer: Some(writer),
59 let mut writer = take_writer!(self); in poll() variables
61 match Pin::new(&mut writer).poll_write(cx, self.buf) {
63 self.writer
99 let mut writer = take_writer!(self); poll() variables
141 let mut writer = take_writer!(self); poll() variables
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| H A D | ylong_sync_rwlock_perf.rs | 38 let mut writer = mutex.write().await; in main() variables
39 *writer += 1; in main()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | input.rs | 29 writer: WriteHalf<S>,
121 writer: WriteHalf<S>,
127 writer,
138 match Pin::new(&mut self.writer) in poll_writer_frame()
167 match Pin::new(&mut self.writer)
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 356 let mut writer = write; in launch() variables
357 if async_send_preface(&mut writer).await.is_ok() { in launch()
360 SendData::new(encoder, send_settings_sync, writer, input_channel.1); in launch()
620 async fn async_send_preface<S>(writer: &mut WriteHalf<S>) -> Result<(), DispatchErrorKind>
625 writer
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | schedule_io.rs | 54 // Reader & writer wakers are for AsyncRead/AsyncWriter
57 writer: Option<Waker>,
142 Interest::WRITABLE => waiters.writer = Some(cx.waker().clone()),
263 if let Some(waker) = waiters.writer.take() { in wake0()
|
Completed in 5 milliseconds