Home
last modified time | relevance | path

Searched +full:merge +full:- +full:stream (Results 1 – 25 of 1118) sorted by relevance

12345678910>>...45

/external/rust/crates/tokio-stream/src/stream_ext/
Dmerge.rs2 use crate::Stream;
9 /// Stream returned by the [`merge`](super::StreamExt::merge) method.
10 pub struct Merge<T, U> {
20 impl<T, U> Merge<T, U> { impl
21 pub(super) fn new(a: T, b: U) -> Merge<T, U> in new()
23 T: Stream, in new() argument
24 U: Stream, in new() argument
26 Merge { in new()
34 impl<T, U> Stream for Merge<T, U> implementation
36 T: Stream,
[all …]
/external/cronet/third_party/protobuf/csharp/src/Google.Protobuf/
DMessageExtensions.cs2 // Protocol Buffers - Google's data interchange format
4 // https://developers.google.com/protocol-buffers/
51 /// <param name="message">The message to merge the data into.</param>
52 … /// <param name="data">The data to merge, which must be protobuf-encoded binary data.</param>
59 /// <param name="message">The message to merge the data into.</param>
60 …/// <param name="data">The data containing the slice to merge, which must be protobuf-encoded bina…
61 /// <param name="offset">The offset of the slice to merge.</param>
62 /// <param name="length">The length of the slice to merge.</param>
69 /// <param name="message">The message to merge the data into.</param>
70 … /// <param name="data">The data to merge, which must be protobuf-encoded binary data.</param>
[all …]
DIMessage.cs2 // Protocol Buffers - Google's data interchange format
4 // https://developers.google.com/protocol-buffers/
45 /// Merges the data from the specified coded input stream with the current message.
47 /// <remarks>See the user guide for precise merge semantics.</remarks>
52 /// Writes the data to the given coded output stream.
54 /// <param name="output">Coded output stream to write the data to. Must not be null.</param>
61 /// to a coded output stream.</returns>
66 /// and for generated types this will be an explicitly-implemented member, returning the
83 /// <remarks>See the user guide for precise merge semantics.</remarks>
84 /// <param name="message">The message to merge with this one. Must not be null.</param>
/external/protobuf/csharp/src/Google.Protobuf/
DMessageExtensions.cs2 // Protocol Buffers - Google's data interchange format
4 // https://developers.google.com/protocol-buffers/
51 /// <param name="message">The message to merge the data into.</param>
52 … /// <param name="data">The data to merge, which must be protobuf-encoded binary data.</param>
59 /// <param name="message">The message to merge the data into.</param>
60 …/// <param name="data">The data containing the slice to merge, which must be protobuf-encoded bina…
61 /// <param name="offset">The offset of the slice to merge.</param>
62 /// <param name="length">The length of the slice to merge.</param>
69 /// <param name="message">The message to merge the data into.</param>
70 … /// <param name="data">The data to merge, which must be protobuf-encoded binary data.</param>
[all …]
DIMessage.cs2 // Protocol Buffers - Google's data interchange format
4 // https://developers.google.com/protocol-buffers/
45 /// Merges the data from the specified coded input stream with the current message.
47 /// <remarks>See the user guide for precise merge semantics.</remarks>
52 /// Writes the data to the given coded output stream.
54 /// <param name="output">Coded output stream to write the data to. Must not be null.</param>
61 /// to a coded output stream.</returns>
66 /// and for generated types this will be an explicitly-implemented member, returning the
83 /// <remarks>See the user guide for precise merge semantics.</remarks>
84 /// <param name="message">The message to merge with this one. Must not be null.</param>
/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/DebugInfo/CodeView/
DTypeStreamMerger.h1 //===- TypeStreamMerger.h ---------------------------------------*- C++ -*-===//
5 // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
7 //===----------------------------------------------------------------------===//
25 /// Merge one set of type records into another. This method assumes
28 /// \param Dest The table to store the re-written type records into.
31 /// type stream, that contains the index of the corresponding type record
32 /// in the destination stream.
34 /// \param Types The collection of types to merge in.
42 /// Merge one set of id records into another. This method assumes
46 /// another type stream (for example using the above method), and accepts
[all …]
/external/swiftshader/third_party/llvm-16.0/llvm/include/llvm/DebugInfo/CodeView/
DTypeStreamMerger.h1 //===- TypeStreamMerger.h ---------------------------------------*- C++ -*-===//
5 // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
7 //===----------------------------------------------------------------------===//
32 /// Merge one set of type records into another. This method assumes
35 /// \param Dest The table to store the re-written type records into.
38 /// type stream, that contains the index of the corresponding type record
39 /// in the destination stream.
41 /// \param Types The collection of types to merge in.
49 /// Merge one set of id records into another. This method assumes
53 /// another type stream (for example using the above method), and accepts
[all …]
/external/cronet/third_party/protobuf/java/core/src/main/java/com/google/protobuf/
DMessageLite.java1 // Protocol Buffers - Google's data interchange format
3 // https://developers.google.com/protocol-buffers/
40 * <p>This interface is implemented by all protocol message objects. Non-lite messages additionally
42 * you only need the subset of features which it supports -- namely, nothing that uses descriptors
50 * <p>This is particularly useful on resource-constrained systems where the full protocol buffers
53 * <p>Note that on non-constrained systems (e.g. servers) when you need to link in lots of protocol
66 * stream.
82 // -----------------------------------------------------------------
105 * {@link #writeTo(CodedOutputStream)}. This does not flush or close the stream.
107 * <p>NOTE: Protocol Buffers are not self-delimiting. Therefore, if you write any more data to the
[all …]
/external/protobuf/java/core/src/main/java/com/google/protobuf/
DMessageLite.java1 // Protocol Buffers - Google's data interchange format
3 // https://developers.google.com/protocol-buffers/
40 * <p>This interface is implemented by all protocol message objects. Non-lite messages additionally
42 * you only need the subset of features which it supports -- namely, nothing that uses descriptors
50 * <p>This is particularly useful on resource-constrained systems where the full protocol buffers
53 * <p>Note that on non-constrained systems (e.g. servers) when you need to link in lots of protocol
66 * stream.
82 // -----------------------------------------------------------------
105 * {@link #writeTo(CodedOutputStream)}. This does not flush or close the stream.
107 * <p>NOTE: Protocol Buffers are not self-delimiting. Therefore, if you write any more data to the
[all …]
/external/rust/crates/tokio-stream/tests/
Dstream_merge.rs1 use tokio_stream::{self as stream, Stream, StreamExt};
13 let mut s = stream::iter(vec![0, 2, 4, 6]).merge(stream::iter(vec![1, 3, 5])); in merge_sync_streams()
16 let rem = 7 - i; in merge_sync_streams()
29 let mut rx = task::spawn(rx1.merge(rx2)); in merge_async_streams()
65 impl tokio_stream::Stream for Monster { in size_overflow()
70 ) -> std::task::Poll<Option<()>> { in size_overflow()
74 fn size_hint(&self) -> (usize, Option<usize>) { in size_overflow()
81 let m = m1.merge(m2); in size_overflow()
/external/rust/crates/tokio-stream/src/
Dstream_ext.rs2 use futures_core::Stream;
34 mod merge; module
35 use merge::Merge;
70 /// An extension trait for the [`Stream`] trait that provides a variety of
73 /// Be aware that the `Stream` trait in Tokio is a re-export of the trait found
76 /// these traits. Click [here][futures-StreamExt] to see the other `StreamExt`
84 /// use futures::stream::StreamExt;
92 /// let merged = tokio_stream::StreamExt::merge(a, b);
94 /// // use normal call notation for futures::stream::StreamExt::collect
100 /// [`Stream`]: crate::Stream
[all …]
Dstream_map.rs1 use crate::Stream;
8 /// Combine many streams into one, indexing each source stream with a unique
11 /// `StreamMap` is similar to [`StreamExt::merge`] in that it combines source
12 /// streams into a single merged stream that yields values in the order that
18 /// * Merge an arbitrary number of streams.
19 /// * Track which source stream the value was received from.
24 /// included with the value when a source stream yields a value. The key is also
25 /// used to remove the stream from the `StreamMap` before the stream has
31 /// keys must be `Unpin`. In order to insert a `!Unpin` stream into a
32 /// `StreamMap`, use [`pin!`] to pin the stream to the stack or [`Box::pin`] to
[all …]
/external/llvm/docs/tutorial/
DOCamlLangImpl5.rst12 LLVM <index.html>`_" tutorial. Parts 1-4 described the implementation of
40 fib(x-1)+fib(x-2);
54 Kaleidoscope allows side-effects, this behavior is important to nail
61 ---------------------------------
66 .. code-block:: ocaml
74 .. code-block:: ocaml
78 | "def" -> [< 'Token.Def; stream >]
79 | "extern" -> [< 'Token.Extern; stream >]
80 | "if" -> [< 'Token.If; stream >]
81 | "then" -> [< 'Token.Then; stream >]
[all …]
/external/mesa3d/src/freedreno/ir3/
Dir3_ra.h7 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
46 struct log_stream *stream = mesa_log_streami(); \
47 mesa_log_stream_printf(stream, "RA: " fmt ": ", ##__VA_ARGS__); \
48 ir3_print_instr_stream(stream, instr); \
49 mesa_log_stream_destroy(stream); \
69 num -= 48 * 4; in ra_num_to_physreg()
78 return (reg->flags & IR3_REG_ARRAY) ? reg->array.base : reg->num; in ra_reg_get_num()
84 return ra_num_to_physreg(ra_reg_get_num(reg), reg->flags); in ra_reg_get_physreg()
98 return (reg->flags & IR3_REG_SSA) && reg->def && def_is_gpr(reg->def); in ra_reg_is_src()
104 return (reg->flags & IR3_REG_SSA) && def_is_gpr(reg) && in ra_reg_is_dst()
[all …]
/external/apache-velocity-engine/velocity-engine-core/src/test/java/org/apache/velocity/test/
DVMLibraryTestCase.java12 * http://www.apache.org/licenses/LICENSE-2.0
39 * Macro library inclution via the Template.merge method is tested using this
130 * Create a file output stream for appending in testVelociMacroLibWithLocalNamespace()
142 template.merge(context, writer, templateList); in testVelociMacroLibWithLocalNamespace()
151 template.merge(context, writer, templateList); in testVelociMacroLibWithLocalNamespace()
165 template.merge(context, writer); in testVelociMacroLibWithLocalNamespace()
198 * Create a file output stream for appending in testVelociMacroLibWithGlobalNamespace()
210 template.merge(context, writer, templateList); in testVelociMacroLibWithGlobalNamespace()
219 template.merge(context, writer, templateList); in testVelociMacroLibWithGlobalNamespace()
260 * Create a file output stream for appending in testVelociMacroLibWithDuplicateDefinitions()
[all …]
/external/python/cpython3/Lib/test/
Dtest_heapq.py32 # The 'merge' function has examples in its docstring which we should test
37 # create a finder which returns the doctests from the merge method.
42 return dtf.find(py_heapq.merge)
82 parentpos = (pos-1) >> 1
101 self.assertEqual(heap, sorted(data)[-10:])
104 # An iterator returning a heap's elements, smallest-first.
112 # Less-naive "N-best" algorithm, much faster (if len(data) is big
116 # (10 log-time steps).
123 self.assertEqual(list(self.heapiter(heap)), sorted(data)[-10:])
135 self.assertEqual(list(self.heapiter(heap)), sorted(data)[-10:])
[all …]
/external/tensorflow/tensorflow/core/kernels/sparse/
Dkernels_gpu.cu.cc7 http://www.apache.org/licenses/LICENSE-2.0
85 /*stream*/ cu_stream); in operator ()()
96 TF_RETURN_IF_ERROR(c->allocate_temp( in operator ()()
109 /*stream*/ cu_stream); in operator ()()
122 // TODO(ebrevdo): Write a custom batch-friendly impl of this to update
131 const int m = csr_row_ptr.size() - 1; // rows in operator ()()
159 d.stream(), indices.data(), coo_row_ind.data(), in operator ()()
164 d.stream(), indices.data(), coo_row_ind.data(), in operator ()()
180 int right = n - 1; in BinarySearchRange()
182 int mid = left + (right - left) / 2; in BinarySearchRange()
[all …]
/external/rust/crates/combine/src/parser/
Dchoice.rs11 ErrorOffset, Parser, Stream, StreamOnce,
23 /// # use combine::stream::easy::Error;
52 ) -> ParseResult<Self::Output, <Input as StreamOnce>::Error> {
60 ) -> ParseResult<Self::Output, Input::Error> {
70 pub trait ChoiceParser<Input: Stream> {
78 ) -> ParseResult<Self::Output, <Input as StreamOnce>::Error>; in parse_first()
84 ) -> ParseResult<Self::Output, <Input as StreamOnce>::Error>; in parse_partial()
91 ) -> ParseResult<Self::Output, <Input as StreamOnce>::Error> in parse_mode_choice()
101 Input: Stream,
114 ) -> ParseResult<Self::Output, <Input as StreamOnce>::Error> in parse_mode_choice()
[all …]
/external/skia/tools/perf-canvaskit-puppeteer/
Dpackage-lock.json2 "name": "perf-canvaskit-puppeteer",
9 "resolved": "https://registry.npmjs.org/@types/node/-/node-14.0.5.tgz",
10 …"integrity": "sha512-90hiq6/VqtQgX8Sp0EzeIsv3r+ellbGj4URKj5j30tLlZvRUpnAe9YbYnjl3pJM93GyXU0tghHhvX…
15 "resolved": "https://registry.npmjs.org/@types/yauzl/-/yauzl-2.9.1.tgz",
16 …"integrity": "sha512-A1b8SU4D10uoPjwb0lnHmmu8wZhR9d+9o2PKBQT2jU5YPTKsxac6M2qGAdY7VcL+dHHhARVUDmeg0…
24 "resolved": "https://registry.npmjs.org/accepts/-/accepts-1.3.8.tgz",
25 …"integrity": "sha512-PYAthTa2m2VKxuvSD3DPC/Gy+U+sOA1LAuT8mkmRuvw+NACSaeXEQ+NHcVF7rONl6qcaxV3Uuemwa…
27 "mime-types": "~2.1.34",
31 "agent-base": {
33 "resolved": "https://registry.npmjs.org/agent-base/-/agent-base-5.1.1.tgz",
[all …]
/external/ComputeLibrary/tests/framework/printers/
DPrinters.h4 * SPDX-License-Identifier: MIT
9 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
45 inline ::std::stringstream &operator>>(::std::stringstream &stream, LogFormat &format)
48 stream >> value;
50 return stream;
53 inline ::std::stringstream &operator<<(::std::stringstream &stream, LogFormat format)
58 stream << "PRETTY";
61 stream << "NONE";
64 stream << "JSON";
70 return stream;
/external/ComputeLibrary/src/graph/frontend/
DStream.cpp2 * Copyright (c) 2018-2019 Arm Limited.
4 * SPDX-License-Identifier: MIT
9 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
24 #include "arm_compute/graph/frontend/Stream.h"
35 Stream::Stream(size_t id, std::string name) in Stream() function in arm_compute::graph::frontend::Stream
40 void Stream::finalize(Target target, const GraphConfig &config) in finalize()
47 void Stream::run() in run()
52 void Stream::add_layer(ILayer &layer) in add_layer()
58 const Graph &Stream::graph() const in graph()
63 Graph &Stream::graph() in graph()
/external/rust/cxx/book/
Dpackage-lock.json2 "name": "cxx-book-build",
8 "name": "cxx-book-build",
12 "html-entities": "^2.3.6"
17 "resolved": "https://registry.npmjs.org/boolbase/-/boolbase-1.0.0.tgz",
18 …"integrity": "sha512-JZOSA7Mo9sNGB8+UjSgzdLtokWAky1zbztM3WRLCbZ70/3cTANmQmOdR7y2g+J0e2WXywy1yS468t…
22 "resolved": "https://registry.npmjs.org/cheerio/-/cheerio-0.22.0.tgz",
23 …"integrity": "sha512-8/MzidM6G/TgRelkzDG13y3Y9LxBjCb+8yOEZ9+wwq5gVF2w2pV0wmHvjfT0RvuxGyR7UEuK36r+y…
25 "css-select": "~1.2.0",
26 "dom-serializer": "~0.1.0",
36 "lodash.merge": "^4.4.0",
[all …]
/external/ComputeLibrary/arm_compute/graph/frontend/
DStream.h2 * Copyright (c) 2018-2020 Arm Limited.
4 * SPDX-License-Identifier: MIT
9 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
44 /** Stream frontend class to construct simple graphs in a stream fashion */
45 class Stream final : public IStream
50 * @param[in] id Stream id
51 * @param[in] name Stream name
53 Stream(size_t id, std::string name);
55 Stream(const Stream &) = delete;
57 Stream &operator=(const Stream &) = delete;
[all …]
/external/aws-sdk-java-v2/.changes/2.16.x/
D2.16.83.json3 "date": "2021-06-11",
21 …on to the video stream. Merge combines the sources into a single stream. Failover allows switching…
27 …"description": "AWS MediaLive now supports OCR-based conversion of DVB-Sub and SCTE-27 image-based…
/external/protobuf/src/google/protobuf/
Dmap_type_handler.h1 // Protocol Buffers - Google's data interchange format
3 // https://developers.google.com/protocol-buffers/
154 uint8_t* ptr, io::EpsCopyOutputStream* stream);
159 static inline void Merge(const Type& from, Type** to, Arena* arena);
200 io::EpsCopyOutputStream* stream); \
204 static inline void Merge(const MapEntryAccessorType& from, \
324 io::EpsCopyOutputStream* stream) {
325 ptr = stream->EnsureSpace(ptr);
327 field, value, value.GetCachedSize(), ptr, stream);
335 io::EpsCopyOutputStream* stream) { \
[all …]

12345678910>>...45