Home
last modified time | relevance | path

Searched refs:TakeWhile (Results 1 – 25 of 462) sorted by relevance

12345678910>>...19

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq/tests/
H A DTakeWhileTests.cs20 Assert.Equal(q.TakeWhile(x => true), q.TakeWhile(x => true)); in SameResultsRepeatCallsIntQuery()
30 Assert.Equal(q.TakeWhile(x => true), q.TakeWhile(x => true)); in SameResultsRepeatCallsStringQuery()
36 Assert.Empty(Enumerable.Empty<int>().TakeWhile(e => true)); in SourceEmpty()
42 Assert.Empty(Enumerable.Empty<int>().TakeWhile((e, i) => true)); in SourceEmptyIndexed()
49 Assert.Empty(source.TakeWhile(x => x % 2 == 0)); in SourceNonEmptyPredicateFalseForAll()
56 Assert.Empty(source.TakeWhile((x, i) => x % 2 == 0)); in SourceNonEmptyPredicateFalseForAllWithIndex()
65 Assert.Equal(expected, source.TakeWhile(x => x % 2 == 0)); in SourceNonEmptyPredicateTrueSomeFalseSecond()
74 Assert.Equal(expected, source.TakeWhile((x, i) => x % 2 == 0)); in SourceNonEmptyPredicateTrueSomeFalseSecondWithIndex()
81 Assert.Empty(source.TakeWhile(x => x % 2 == 0)); in SourceNonEmptyPredicateTrueSomeFalseFirst()
88 Assert.Empty(source.TakeWhile((x, i) => x % 2 == 0)); in SourceNonEmptyPredicateTrueSomeFalseFirstWithIndex()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq.Queryable/tests/
H A DTakeWhileTests.cs18 Assert.Equal(expected, source.AsQueryable().TakeWhile(x => x % 2 == 0)); in SourceNonEmptyPredicateTrueSomeFalseSecond()
27 Assert.Equal(expected, source.AsQueryable().TakeWhile((x, i) => x % 2 == 0)); in SourceNonEmptyPredicateTrueSomeFalseSecondWithIndex()
34 … AssertExtensions.Throws<ArgumentNullException>("source", () => source.TakeWhile(x => true)); in ThrowsOnNullSource()
42 …AssertExtensions.Throws<ArgumentNullException>("predicate", () => source.TakeWhile(nullPredicate)); in ThrowsOnNullPredicate()
49 … AssertExtensions.Throws<ArgumentNullException>("source", () => source.TakeWhile((x, i) => true)); in ThrowsOnNullSourceIndexed()
57 …AssertExtensions.Throws<ArgumentNullException>("predicate", () => source.TakeWhile(nullPredicate)); in ThrowsOnNullPredicateIndexed()
63 var count = (new int[] { 0, 1, 2 }).AsQueryable().TakeWhile(n => n < 2).Count(); in TakeWhile1()
70 … var count = (new int[] { 0, 1, 2 }).AsQueryable().TakeWhile((n, i) => n + i < 4).Count(); in TakeWhile2()
/dports/multimedia/termplay/termplay-2.0.6/cargo-crates/futures-util-0.3.1/src/stream/stream/
H A Dtake_while.rs12 pub struct TakeWhile<St: Stream , Fut, F> { struct
20 impl<St: Unpin + Stream, Fut: Unpin, F> Unpin for TakeWhile<St, Fut, F> {} argument
22 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> implementation
38 impl<St: Stream, Fut, F> TakeWhile<St, Fut, F> { implementation
46 impl<St, Fut, F> TakeWhile<St, Fut, F> implementation
51 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
52 TakeWhile { in new()
94 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
146 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
158 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/net/proby/proby-1.0.2/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/stream/
H A Dtake_while.rs12 pub struct TakeWhile<St: Stream , Fut, F> { struct
20 impl<St: Unpin + Stream, Fut: Unpin, F> Unpin for TakeWhile<St, Fut, F> {} argument
22 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> implementation
38 impl<St: Stream, Fut, F> TakeWhile<St, Fut, F> { impl
46 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
51 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
52 TakeWhile { in new()
94 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
146 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
158 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/stream/
H A Dtake_while.rs12 pub struct TakeWhile<St: Stream , Fut, F> { struct
20 impl<St: Unpin + Stream, Fut: Unpin, F> Unpin for TakeWhile<St, Fut, F> {} argument
22 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> implementation
38 impl<St: Stream, Fut, F> TakeWhile<St, Fut, F> { impl
46 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
51 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
52 TakeWhile { in new()
94 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
146 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
158 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/futures-util/src/stream/stream/
H A Dtake_while.rs12 pub struct TakeWhile<St: Stream , Fut, F> { struct
20 impl<St: Unpin + Stream, Fut: Unpin, F> Unpin for TakeWhile<St, Fut, F> {} argument
22 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> implementation
38 impl<St: Stream, Fut, F> TakeWhile<St, Fut, F> { implementation
46 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
51 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
52 TakeWhile { in new()
94 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
146 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
158 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/futures-util-0.3.4/src/stream/stream/
H A Dtake_while.rs12 pub struct TakeWhile<St: Stream , Fut, F> { struct
20 impl<St: Unpin + Stream, Fut: Unpin, F> Unpin for TakeWhile<St, Fut, F> {} implementation
22 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> implementation
38 impl<St: Stream, Fut, F> TakeWhile<St, Fut, F> { impl
46 impl<St, Fut, F> TakeWhile<St, Fut, F> implementation
51 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
52 TakeWhile { in new()
94 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
146 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
158 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/futures-util-0.3.5/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> implementation
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/games/genact/genact-0.10.0/cargo-crates/futures-util-0.3.5/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/sysutils/vector/vector-0.10.0/cargo-crates/futures-util-0.3.5/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> implementation
39 impl<St, Fut, F> TakeWhile<St, Fut, F> implementation
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/net/proby/proby-1.0.2/cargo-crates/futures-util-0.3.5/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-util-0.3.5/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/net-im/fractal/fractal-4.4.0/vendor/futures-util/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/audio/spotify-tui/spotify-tui-0.25.0/cargo-crates/futures-util-0.3.5/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/sysutils/tealdeer/tealdeer-1.4.1/cargo-crates/futures-util-0.3.5/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> implementation
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
74 … let TakeWhile { mut stream, f, mut pending_fut, pending_item, done_taking } = self.project(); in poll_next() localVariable
111 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
123 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/lang/rust/rustc-1.58.1-src/library/core/src/iter/adapters/
H A Dtake_while.rs15 pub struct TakeWhile<I, P> { struct
21 impl<I, P> TakeWhile<I, P> { argument
22 pub(in crate::iter) fn new(iter: I, predicate: P) -> TakeWhile<I, P> { in new()
23 TakeWhile { iter, flag: false, predicate } in new()
28 impl<I: fmt::Debug, P> fmt::Debug for TakeWhile<I, P> { implementation
35 impl<I: Iterator, P> Iterator for TakeWhile<I, P> implementation
113 impl<I, P> FusedIterator for TakeWhile<I, P> implementation
121 unsafe impl<P, I> SourceIter for TakeWhile<I, P> implementation
135 unsafe impl<I: InPlaceIterable, F> InPlaceIterable for TakeWhile<I, F> where implementation
/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/
H A DTakeWhile.cs8 class TakeWhile<TSource> : Producer<TSource> class
14 public TakeWhile(IObservable<TSource> source, Func<TSource, bool> predicate) in TakeWhile() method in System.Reactive.Linq.ObservableImpl.TakeWhile
20 public TakeWhile(IObservable<TSource> source, Func<TSource, int, bool> predicate) in TakeWhile() method in System.Reactive.Linq.ObservableImpl.TakeWhile
44 private readonly TakeWhile<TSource> _parent;
47 public _(TakeWhile<TSource> parent, IObserver<TSource> observer, IDisposable cancel) in _()
96 private readonly TakeWhile<TSource> _parent;
100 … public TakeWhileImpl(TakeWhile<TSource> parent, IObserver<TSource> observer, IDisposable cancel) in TakeWhileImpl()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq.Parallel/tests/QueryOperators/
H A DTakeTakeWhileTests.cs140 foreach (int i in UnorderedSources.Default(count).TakeWhile(x => x < take)) in TakeWhile_Unordered()
157 public static void TakeWhile(Labeled<ParallelQuery<int>> labeled, int count, int take) in TakeWhile() method in System.Linq.Parallel.Tests.TakeTakeWhileTests
161 foreach (int i in query.TakeWhile(x => x < take)) in TakeWhile()
173 TakeWhile(labeled, count, take); in TakeWhile_Longrunning()
201 Assert.All(query.TakeWhile(x => x < take).ToList(), x => Assert.Equal(seen++, x)); in TakeWhile_NotPipelined()
220 foreach (int i in UnorderedSources.Default(count).TakeWhile((x, index) => index < take)) in TakeWhile_Indexed_Unordered()
241 foreach (int i in query.TakeWhile((x, index) => index < take)) in TakeWhile_Indexed()
297 Assert.Empty(UnorderedSources.Default(count).TakeWhile(x => false)); in TakeWhile_AllFalse()
314 Assert.All(query.TakeWhile(x => true), x => Assert.Equal(seen++, x)); in TakeWhile_AllTrue()
332 Assert.All(query.TakeWhile(x => take.Contains(x)), x => Assert.Equal(seen++, x)); in TakeWhile_SomeTrue()
[all …]
/dports/lang/rust/rustc-1.58.1-src/src/test/ui/issues/
H A Dissue-31173.stderr1 error[E0271]: type mismatch resolving `<TakeWhile<&mut std::vec::IntoIter<u8>, [closure@$DIR/issue-…
15 error[E0599]: the method `collect` exists for struct `Cloned<TakeWhile<&mut std::vec::IntoIter<u8>,…
19 …| ^^^^^^^ method cannot be called on `Cloned<TakeWhile<&mut std::vec::IntoIter<u8>, [clos…
28 LL | pub struct TakeWhile<I, P> {
32 …`<TakeWhile<&mut std::vec::IntoIter<u8>, [closure@$DIR/issue-31173.rs:6:39: 9:6]> as Iterator>::It…
33 …which is required by `Cloned<TakeWhile<&mut std::vec::IntoIter<u8>, [closure@$DIR/issue-31173.rs:6…
34 …`Cloned<TakeWhile<&mut std::vec::IntoIter<u8>, [closure@$DIR/issue-31173.rs:6:39: 9:6]>>: Iterator`
35 …which is required by `&mut Cloned<TakeWhile<&mut std::vec::IntoIter<u8>, [closure@$DIR/issue-31173…
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/futures-util-0.3.7/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> impl
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
109 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
121 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/www/castor/castor-0.8.16/cargo-crates/futures-util-0.3.6/src/stream/stream/
H A Dtake_while.rs13 pub struct TakeWhile<St: Stream, Fut, F> { struct
23 impl<St, Fut, F> fmt::Debug for TakeWhile<St, Fut, F> argument
39 impl<St, Fut, F> TakeWhile<St, Fut, F> implementation
44 pub(super) fn new(stream: St, f: F) -> TakeWhile<St, Fut, F> { in new()
45 TakeWhile { in new()
57 impl<St, Fut, F> Stream for TakeWhile<St, Fut, F> implementation
109 impl<St, Fut, F> FusedStream for TakeWhile<St, Fut, F> implementation
121 impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> implementation
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/futures-0.1.29/src/stream/
H A Dtake_while.rs10 pub struct TakeWhile<S, P, R> where S: Stream, R: IntoFuture { struct
17 pub fn new<S, P, R>(s: S, p: P) -> TakeWhile<S, P, R> in new() argument
22 TakeWhile { in new()
30 impl<S, P, R> TakeWhile<S, P, R> where S: Stream, R: IntoFuture { impl
56 impl<S, P, R> ::sink::Sink for TakeWhile<S, P, R> implementation
75 impl<S, P, R> Stream for TakeWhile<S, P, R> implementation
/dports/devel/sccache/sccache-0.2.15/cargo-crates/futures-0.1.30/src/stream/
H A Dtake_while.rs10 pub struct TakeWhile<S, P, R> where S: Stream, R: IntoFuture { struct
17 pub fn new<S, P, R>(s: S, p: P) -> TakeWhile<S, P, R> in new() argument
22 TakeWhile { in new()
30 impl<S, P, R> TakeWhile<S, P, R> where S: Stream, R: IntoFuture { impl
56 impl<S, P, R> ::sink::Sink for TakeWhile<S, P, R> implementation
75 impl<S, P, R> Stream for TakeWhile<S, P, R> implementation
/dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/futures-0.1.29/src/stream/
H A Dtake_while.rs10 pub struct TakeWhile<S, P, R> where S: Stream, R: IntoFuture { struct
17 pub fn new<S, P, R>(s: S, p: P) -> TakeWhile<S, P, R> in new() argument
22 TakeWhile { in new()
30 impl<S, P, R> TakeWhile<S, P, R> where S: Stream, R: IntoFuture { implementation
56 impl<S, P, R> ::sink::Sink for TakeWhile<S, P, R> implementation
75 impl<S, P, R> Stream for TakeWhile<S, P, R> implementation
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/futures/src/stream/
H A Dtake_while.rs10 pub struct TakeWhile<S, P, R> where S: Stream, R: IntoFuture { struct
17 pub fn new<S, P, R>(s: S, p: P) -> TakeWhile<S, P, R> in new() argument
22 TakeWhile { in new()
30 impl<S, P, R> TakeWhile<S, P, R> where S: Stream, R: IntoFuture { implementation
56 impl<S, P, R> ::sink::Sink for TakeWhile<S, P, R> implementation
75 impl<S, P, R> Stream for TakeWhile<S, P, R> implementation

12345678910>>...19