| 132 | } |
| 133 | |
| 134 | fn create_stream() -> DataStream<'static, &'static str, i32> { |
| 135 | let metadata = vec![ |
| 136 | Channel { |
| 137 | name: "Series 1", |
| 138 | tag: 0, |
| 139 | visible: true, |
| 140 | }, |
| 141 | Channel { |
| 142 | name: "Series 2", |
| 143 | tag: 1, |
| 144 | visible: true, |
| 145 | }, |
| 146 | Channel { |
| 147 | name: "Series 3", |
| 148 | tag: 2, |
| 149 | visible: true, |
| 150 | }, |
| 151 | ]; |
| 152 | |
| 153 | // Zero stream tag is allways metric |
| 154 | let mut frames = vec![DataFrame { |
| 155 | metric: "Monday", |
| 156 | data: [(0, 1), (1, 3), (2, 5)].iter().cloned().collect(), |
| 157 | }]; |
| 158 | |
| 159 | frames.push(DataFrame { |
| 160 | metric: "Tuesday", |
| 161 | data: [(0, 3), (1, 4), (2, 6)].iter().cloned().collect(), |
| 162 | }); |
| 163 | |
| 164 | frames.push(DataFrame { |
| 165 | metric: "Wednesday", |
| 166 | data: [(0, 4), (1, 3), (2, 1)].iter().cloned().collect(), |
| 167 | }); |
| 168 | |
| 169 | // let skip one stream flow |
| 170 | frames.push(DataFrame { |
| 171 | metric: "Thursday", |
| 172 | data: [(1, 5), (2, 1)].iter().cloned().collect(), |
| 173 | }); |
| 174 | |
| 175 | frames.push(DataFrame { |
| 176 | metric: "Friday", |
| 177 | data: [(0, 3), (1, 4), (2, 2)].iter().cloned().collect(), |
| 178 | }); |
| 179 | |
| 180 | frames.push(DataFrame { |
| 181 | metric: "Saturday", |
| 182 | data: [(0, 5), (1, 10), (2, 4)].iter().cloned().collect(), |
| 183 | }); |
| 184 | |
| 185 | frames.push(DataFrame { |
| 186 | metric: "Sunday", |
| 187 | data: [(0, 4), (1, 12), (2, 8)].iter().cloned().collect(), |
| 188 | }); |
| 189 | |
| 190 | DataStream::new(metadata, frames) |
| 191 | } |