/rust/registry/src/index.crates.io-1949cf8c6b5b557f/itertools-0.14.0/src/sources.rs
Line | Count | Source |
1 | | //! Iterators that are sources (produce elements from parameters, |
2 | | //! not from another iterator). |
3 | | #![allow(deprecated)] |
4 | | |
5 | | use std::fmt; |
6 | | use std::mem; |
7 | | |
8 | | /// Creates a new unfold source with the specified closure as the "iterator |
9 | | /// function" and an initial state to eventually pass to the closure |
10 | | /// |
11 | | /// `unfold` is a general iterator builder: it has a mutable state value, |
12 | | /// and a closure with access to the state that produces the next value. |
13 | | /// |
14 | | /// This more or less equivalent to a regular struct with an [`Iterator`] |
15 | | /// implementation, and is useful for one-off iterators. |
16 | | /// |
17 | | /// ``` |
18 | | /// // an iterator that yields sequential Fibonacci numbers, |
19 | | /// // and stops at the maximum representable value. |
20 | | /// |
21 | | /// use itertools::unfold; |
22 | | /// |
23 | | /// let mut fibonacci = unfold((1u32, 1u32), |(x1, x2)| { |
24 | | /// // Attempt to get the next Fibonacci number |
25 | | /// let next = x1.saturating_add(*x2); |
26 | | /// |
27 | | /// // Shift left: ret <- x1 <- x2 <- next |
28 | | /// let ret = *x1; |
29 | | /// *x1 = *x2; |
30 | | /// *x2 = next; |
31 | | /// |
32 | | /// // If addition has saturated at the maximum, we are finished |
33 | | /// if ret == *x1 && ret > 1 { |
34 | | /// None |
35 | | /// } else { |
36 | | /// Some(ret) |
37 | | /// } |
38 | | /// }); |
39 | | /// |
40 | | /// itertools::assert_equal(fibonacci.by_ref().take(8), |
41 | | /// vec![1, 1, 2, 3, 5, 8, 13, 21]); |
42 | | /// assert_eq!(fibonacci.last(), Some(2_971_215_073)) |
43 | | /// ``` |
44 | | #[deprecated( |
45 | | note = "Use [std::iter::from_fn](https://doc.rust-lang.org/std/iter/fn.from_fn.html) instead", |
46 | | since = "0.13.0" |
47 | | )] |
48 | 0 | pub fn unfold<A, St, F>(initial_state: St, f: F) -> Unfold<St, F> |
49 | 0 | where |
50 | 0 | F: FnMut(&mut St) -> Option<A>, |
51 | | { |
52 | 0 | Unfold { |
53 | 0 | f, |
54 | 0 | state: initial_state, |
55 | 0 | } |
56 | 0 | } |
57 | | |
58 | | impl<St, F> fmt::Debug for Unfold<St, F> |
59 | | where |
60 | | St: fmt::Debug, |
61 | | { |
62 | | debug_fmt_fields!(Unfold, state); |
63 | | } |
64 | | |
65 | | /// See [`unfold`](crate::unfold) for more information. |
66 | | #[derive(Clone)] |
67 | | #[must_use = "iterators are lazy and do nothing unless consumed"] |
68 | | #[deprecated( |
69 | | note = "Use [std::iter::FromFn](https://doc.rust-lang.org/std/iter/struct.FromFn.html) instead", |
70 | | since = "0.13.0" |
71 | | )] |
72 | | pub struct Unfold<St, F> { |
73 | | f: F, |
74 | | /// Internal state that will be passed to the closure on the next iteration |
75 | | pub state: St, |
76 | | } |
77 | | |
78 | | impl<A, St, F> Iterator for Unfold<St, F> |
79 | | where |
80 | | F: FnMut(&mut St) -> Option<A>, |
81 | | { |
82 | | type Item = A; |
83 | | |
84 | | #[inline] |
85 | 0 | fn next(&mut self) -> Option<Self::Item> { |
86 | 0 | (self.f)(&mut self.state) |
87 | 0 | } |
88 | | } |
89 | | |
90 | | /// An iterator that infinitely applies function to value and yields results. |
91 | | /// |
92 | | /// This `struct` is created by the [`iterate()`](crate::iterate) function. |
93 | | /// See its documentation for more. |
94 | | #[derive(Clone)] |
95 | | #[must_use = "iterators are lazy and do nothing unless consumed"] |
96 | | pub struct Iterate<St, F> { |
97 | | state: St, |
98 | | f: F, |
99 | | } |
100 | | |
101 | | impl<St, F> fmt::Debug for Iterate<St, F> |
102 | | where |
103 | | St: fmt::Debug, |
104 | | { |
105 | | debug_fmt_fields!(Iterate, state); |
106 | | } |
107 | | |
108 | | impl<St, F> Iterator for Iterate<St, F> |
109 | | where |
110 | | F: FnMut(&St) -> St, |
111 | | { |
112 | | type Item = St; |
113 | | |
114 | | #[inline] |
115 | 0 | fn next(&mut self) -> Option<Self::Item> { |
116 | 0 | let next_state = (self.f)(&self.state); |
117 | 0 | Some(mem::replace(&mut self.state, next_state)) |
118 | 0 | } |
119 | | |
120 | | #[inline] |
121 | 0 | fn size_hint(&self) -> (usize, Option<usize>) { |
122 | 0 | (usize::MAX, None) |
123 | 0 | } |
124 | | } |
125 | | |
126 | | /// Creates a new iterator that infinitely applies function to value and yields results. |
127 | | /// |
128 | | /// ``` |
129 | | /// use itertools::iterate; |
130 | | /// |
131 | | /// itertools::assert_equal(iterate(1, |i| i % 3 + 1).take(5), vec![1, 2, 3, 1, 2]); |
132 | | /// ``` |
133 | | /// |
134 | | /// **Panics** if compute the next value does. |
135 | | /// |
136 | | /// ```should_panic |
137 | | /// # use itertools::iterate; |
138 | | /// let mut it = iterate(25u32, |x| x - 10).take_while(|&x| x > 10); |
139 | | /// assert_eq!(it.next(), Some(25)); // `Iterate` holds 15. |
140 | | /// assert_eq!(it.next(), Some(15)); // `Iterate` holds 5. |
141 | | /// it.next(); // `5 - 10` overflows. |
142 | | /// ``` |
143 | | /// |
144 | | /// You can alternatively use [`core::iter::successors`] as it better describes a finite iterator. |
145 | 0 | pub fn iterate<St, F>(initial_value: St, f: F) -> Iterate<St, F> |
146 | 0 | where |
147 | 0 | F: FnMut(&St) -> St, |
148 | | { |
149 | 0 | Iterate { |
150 | 0 | state: initial_value, |
151 | 0 | f, |
152 | 0 | } |
153 | 0 | } |