Home
last modified time | relevance | path

Searched defs:new (Results 1 – 25 of 138) sorted by relevance

123456

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
Dwrite_task.rs44 pub(crate) fn new(writer: &'a mut W, buf: &'a [u8]) -> WriteTask<'a, W> { in new() function
84 pub(crate) fn new(writer: &'a mut W, bufs: &'a [IoSlice<'b>]) -> WriteVectoredTask<'a, 'b, W> { in new() function
125 pub(crate) fn new(writer: &'a mut W, buf: &'a [u8]) -> WriteAllTask<'a, W> { in new() function
166 pub(crate) fn new(writer: &'a mut W) -> FlushTask<'a, W> { in new() function
191 pub(crate) fn new(writer: &'a mut W) -> ShutdownTask<'a, W> { in new() function
Dread_task.rs47 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadTask<'a, R> { in new() method
87 pub(crate) fn new(reader: &'a mut R, buf: &'a mut Vec<u8>) -> ReadToEndTask<'a, R> { in new() method
158 pub(crate) fn new(reader: &'a mut R, dst: &'a mut String) -> ReadToStringTask<'a, R> { in new() method
230 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadExactTask<'a, R> { in new() method
280 pub(crate) fn new(reader: &'a mut R, delim: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, R> { in new() method
348 pub(crate) fn new(reader: &'a mut R, buf: &'a mut String) -> ReadLineTask<'a, R> { in new() method
390 pub(crate) fn new(reader: R, delim: u8) -> SplitTask<R> { in new() function
434 pub(crate) fn new(reader: R) -> LinesTask<R> { in new() function
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/
Dchannel.rs27 fn new(chan: C) -> Channel<C> { in new() method
54 fn new(channel: Arc<Channel<C>>) -> Tx<C> { in new() method
82 fn new(channel: Arc<Channel<C>>) -> Rx<C> { in new() method
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
Dencoder.rs33 pub(crate) fn new(table: &'a mut DynamicTable) -> Self { in new() method
128 pub(crate) fn new() -> Self { in new() method
166 fn new(parts: Parts) -> Self { in new() method
243 fn new(index: usize) -> Self { in new() method
260 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new() method
283 fn new(name: Vec<u8>, value: Vec<u8>, is_huffman: bool) -> Self { in new() method
306 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new() method
329 fn new(name: Vec<u8>, value: Vec<u8>, is_huffman: bool) -> Self { in new() method
352 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new() method
375 fn new(name: Vec<u8>, value: Vec<u8>, is_huffman: bool) -> Self { in new() method
[all …]
Ddecoder.rs35 pub(crate) fn new(buf: &'a [u8]) -> Self { in new() method
84 pub(crate) fn new() -> Self { in new() method
160 fn new() -> Self { in new() method
198 fn new(repr: PrefixBit) -> Self { in new() method
227 fn new(repr: PrefixBit, name: Name) -> Self { in new() method
322 fn new(repr: PrefixBit, index: IntegerDecoder) -> Self { in new() method
402 fn new(is_huffman: bool, length: IntegerDecoder) -> Self { in new() method
442 fn new(length: usize) -> Self { in new() method
485 fn new(length: usize) -> Self { in new() method
526 fn new(repr: PrefixBit, name: Name, value: Vec<u8>) -> Self { in new() method
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
Dframe.rs209 pub fn new(id: StreamId, flags: FrameFlags, payload: Payload) -> Self { in new() method
232 pub fn new(flags: u8) -> Self { in new() method
325 pub fn new(parts: Parts) -> Self { in new() method
342 pub fn new(data: Vec<u8>) -> Self { in new() method
354 pub fn new(settings: Vec<Setting>) -> Self { in new() method
402 pub fn new() -> Self { in new() method
457 pub fn new(error_code: u32, last_stream_id: StreamId, debug_data: Vec<u8>) -> Self { in new() method
490 pub fn new(window_size_increment: u32) -> Self { in new() method
510 pub fn new(exclusive: bool, stream_dependency: u32, weight: u8) -> Self { in new() method
536 pub fn new(error_code: u32) -> Self { in new() method
[all …]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
Dnormalizer.rs29 pub(crate) fn new(part: &'a mut Request<T>) -> Self { in new() method
57 pub(crate) fn new() -> Self { in new() method
119 pub(crate) fn new(req_method: &'a Method, part: &'a ResponsePart) -> Self { in new() method
Dpool.rs28 pub(crate) fn new() -> Self { in new() method
52 pub(crate) fn new(scheme: Scheme, authority: Authority) -> Self { in new() method
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/
Dcurrent_thread_builder.rs27 pub(crate) fn new() -> Self { in new() method
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
Dpool.rs31 pub(crate) fn new(connector: C) -> Self { in new() method
55 fn new() -> Self { in new() method
/commonlibrary/rust/ylong_runtime/ylong_io/src/
Dwaker.rs27 pub fn new(poll: &Poll, token: Token) -> io::Result<Self> { in new() method
/commonlibrary/rust/ylong_http/ylong_http/src/h1/request/
Dencoder.rs182 pub fn new(part: RequestPart) -> Self { in new() method
420 fn new(method: Method) -> Self { in new() method
441 fn new(uri: Uri, is_proxy: bool) -> Self { in new() method
473 fn new(version: Version) -> Self { in new() method
506 fn new(header: Headers) -> Self { in new() method
606 fn new() -> Self { in new() method
622 fn new() -> Self { in new() method
640 fn new(src: &'a [u8], src_idx: &'a mut usize, dst: &'a mut [u8]) -> Self { in new() method
/commonlibrary/ets_utils/js_api_module/xml/src/
Djs_xml.ts17 new(value: object, strEncoding?: string): NativeXmlPullParser; method
23 new(value: object, strEncoding?: string): NativeXMLSerializer; method
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dtimer_test.rs29 fn new() -> Self { in new() method
58 fn new() -> Self { in new() method
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
Dwaiter.rs57 pub fn new() -> Waiter { in new() method
Dsemaphore.rs104 pub fn new(permits: usize) -> Result<Semaphore, SemaphoreError> { in new() method
235 pub fn new(number: usize) -> Result<AutoRelSemaphore, SemaphoreError> { in new() method
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
Dwaker.rs28 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> { in new() method
Dhandle.rs23 pub(crate) fn new(handle: HANDLE) -> Self { in new() method
Diocp.rs36 pub(crate) fn new() -> io::Result<CompletionPort> { in new() method
121 pub(crate) fn new(bytes: u32, token: usize, overlapped: *mut Overlapped) -> Self { in new() method
Dnet.rs38 pub(crate) fn new() -> NetState { in new() method
125 pub(crate) fn new( in new() method
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
Dasync_source.rs64 pub fn new(mut io: E, interest: Option<Interest>) -> io::Result<AsyncSource<E>> { in new() method
88 pub fn new(mut io: E, interest: Option<Interest>) -> io::Result<AsyncSource<E>> { in new() method
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/
Dhttp.rs27 pub(crate) fn new() -> Self { in new() method
89 pub fn new() -> Self { in new() method
Dclient.rs28 pub(crate) fn new() -> Self { in new() method
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/
Dwaker.rs29 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> { in new() method
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
Dpool.rs32 pub(crate) fn new(config: HttpConfig, connector: C) -> Self { in new() method
61 fn new() -> Self { in new() method

123456