1#![no_std]
2
3pub use rx_core_common::*;
4
5pub mod observable {
6 #[cfg(feature = "observable_closed")]
7 pub use rx_core_observable_closed::observable::*;
8 #[cfg(feature = "observable_combine_changes")]
9 pub use rx_core_observable_combine_changes::observable::*;
10 #[cfg(feature = "observable_combine_latest")]
11 pub use rx_core_observable_combine_latest::observable::*;
12 #[cfg(feature = "observable_concat")]
13 pub use rx_core_observable_concat::observable::*;
14 #[cfg(feature = "observable_connectable")]
15 pub use rx_core_observable_connectable::observable::*;
16 #[cfg(feature = "observable_create")]
17 pub use rx_core_observable_create::observable::*;
18 #[cfg(feature = "observable_deferred")]
19 pub use rx_core_observable_deferred::observable::*;
20 #[cfg(feature = "observable_empty")]
21 pub use rx_core_observable_empty::observable::*;
22 #[cfg(feature = "observable_interval")]
23 pub use rx_core_observable_interval::observable::*;
24 #[cfg(feature = "observable_iterator")]
25 pub use rx_core_observable_iterator::observable::*;
26 #[cfg(feature = "observable_iterator_on_tick")]
27 pub use rx_core_observable_iterator_on_tick::observable::*;
28 #[cfg(feature = "observable_join")]
29 pub use rx_core_observable_join::observable::*;
30 #[cfg(feature = "observable_just")]
31 pub use rx_core_observable_just::observable::*;
32 #[cfg(feature = "observable_merge")]
33 pub use rx_core_observable_merge::observable::*;
34 #[cfg(feature = "observable_never")]
35 pub use rx_core_observable_never::observable::*;
36 #[cfg(feature = "observable_throw")]
37 pub use rx_core_observable_throw::observable::*;
38 #[cfg(feature = "observable_timer")]
39 pub use rx_core_observable_timer::observable::*;
40 #[cfg(feature = "observable_zip")]
41 pub use rx_core_observable_zip::observable::*;
42}
43
44#[cfg(feature = "observable_fn")]
45pub mod observable_fn {
46 #[cfg(feature = "observable_closed")]
47 pub use rx_core_observable_closed::observable_fn::*;
48 #[cfg(feature = "observable_combine_changes")]
49 pub use rx_core_observable_combine_changes::observable_fn::*;
50 #[cfg(feature = "observable_combine_latest")]
51 pub use rx_core_observable_combine_latest::observable_fn::*;
52 #[cfg(feature = "observable_concat")]
53 pub use rx_core_observable_concat::observable_fn::*;
54 #[cfg(feature = "observable_create")]
55 pub use rx_core_observable_create::observable_fn::*;
56 #[cfg(feature = "observable_deferred")]
57 pub use rx_core_observable_deferred::observable_fn::*;
58 #[cfg(feature = "observable_empty")]
59 pub use rx_core_observable_empty::observable_fn::*;
60 #[cfg(feature = "observable_interval")]
61 pub use rx_core_observable_interval::observable_fn::*;
62 #[cfg(feature = "observable_join")]
63 pub use rx_core_observable_join::observable_fn::*;
64 #[cfg(feature = "observable_just")]
65 pub use rx_core_observable_just::observable_fn::*;
66 #[cfg(feature = "observable_merge")]
67 pub use rx_core_observable_merge::observable_fn::*;
68 #[cfg(feature = "observable_never")]
69 pub use rx_core_observable_never::observable_fn::*;
70 #[cfg(feature = "observable_throw")]
71 pub use rx_core_observable_throw::observable_fn::*;
72 #[cfg(feature = "observable_timer")]
73 pub use rx_core_observable_timer::observable_fn::*;
74 #[cfg(feature = "observable_zip")]
75 pub use rx_core_observable_zip::observable_fn::*;
76}
77
78pub mod operator {
79 #[cfg(feature = "operator_adsr")]
80 pub use rx_core_operator_adsr::operator::*;
81 #[cfg(feature = "operator_buffer_count")]
82 pub use rx_core_operator_buffer_count::operator::*;
83 #[cfg(feature = "operator_catch")]
84 pub use rx_core_operator_catch::operator::*;
85 #[cfg(feature = "operator_composite")]
86 pub use rx_core_operator_composite::operator::*;
87 #[cfg(feature = "operator_concat_all")]
88 pub use rx_core_operator_concat_all::operator::*;
89 #[cfg(feature = "operator_concat_map")]
90 pub use rx_core_operator_concat_map::operator::*;
91 #[cfg(feature = "operator_count")]
92 pub use rx_core_operator_count::operator::*;
93 #[cfg(feature = "operator_delay")]
94 pub use rx_core_operator_delay::operator::*;
95 #[cfg(feature = "operator_dematerialize")]
96 pub use rx_core_operator_dematerialize::operator::*;
97 #[cfg(feature = "operator_element_at")]
98 pub use rx_core_operator_element_at::operator::*;
99 #[cfg(feature = "operator_end_with")]
100 pub use rx_core_operator_end_with::operator::*;
101 #[cfg(feature = "operator_enumerate")]
102 pub use rx_core_operator_enumerate::operator::*;
103 #[cfg(feature = "operator_error_boundary")]
104 pub use rx_core_operator_error_boundary::operator::*;
105 #[cfg(feature = "operator_exhaust_all")]
106 pub use rx_core_operator_exhaust_all::operator::*;
107 #[cfg(feature = "operator_exhaust_map")]
108 pub use rx_core_operator_exhaust_map::operator::*;
109 #[cfg(feature = "operator_fallback_when_silent")]
110 pub use rx_core_operator_fallback_when_silent::operator::*;
111 #[cfg(feature = "operator_filter")]
112 pub use rx_core_operator_filter::operator::*;
113 #[cfg(feature = "operator_filter_map")]
114 pub use rx_core_operator_filter_map::operator::*;
115 #[cfg(feature = "operator_finalize")]
116 pub use rx_core_operator_finalize::operator::*;
117 #[cfg(feature = "operator_find")]
118 pub use rx_core_operator_find::operator::*;
119 #[cfg(feature = "operator_find_index")]
120 pub use rx_core_operator_find_index::operator::*;
121 #[cfg(feature = "operator_first")]
122 pub use rx_core_operator_first::operator::*;
123 #[cfg(feature = "operator_identity")]
124 pub use rx_core_operator_identity::operator::*;
125 #[cfg(feature = "operator_into_result")]
126 pub use rx_core_operator_into_result::operator::*;
127 #[cfg(feature = "operator_is_empty")]
128 pub use rx_core_operator_is_empty::operator::*;
129 #[cfg(feature = "operator_lift_option")]
130 pub use rx_core_operator_lift_option::operator::*;
131 #[cfg(feature = "operator_lift_result")]
132 pub use rx_core_operator_lift_result::operator::*;
133 #[cfg(feature = "operator_map")]
134 pub use rx_core_operator_map::operator::*;
135 #[cfg(feature = "operator_map_error")]
136 pub use rx_core_operator_map_error::operator::*;
137 #[cfg(feature = "operator_map_into")]
138 pub use rx_core_operator_map_into::operator::*;
139 #[cfg(feature = "operator_map_never")]
140 pub use rx_core_operator_map_never::operator::*;
141 #[cfg(feature = "operator_materialize")]
142 pub use rx_core_operator_materialize::operator::*;
143 #[cfg(feature = "operator_merge_all")]
144 pub use rx_core_operator_merge_all::operator::*;
145 #[cfg(feature = "operator_merge_map")]
146 pub use rx_core_operator_merge_map::operator::*;
147 #[cfg(feature = "operator_observe_on")]
148 pub use rx_core_operator_observe_on::operator::*;
149 #[cfg(feature = "operator_on_next")]
150 pub use rx_core_operator_on_next::operator::*;
151 #[cfg(feature = "operator_on_subscribe")]
152 pub use rx_core_operator_on_subscribe::operator::*;
153 #[cfg(feature = "operator_pairwise")]
154 pub use rx_core_operator_pairwise::operator::*;
155 #[cfg(feature = "operator_reduce")]
156 pub use rx_core_operator_reduce::operator::*;
157 #[cfg(feature = "operator_retry")]
158 pub use rx_core_operator_retry::operator::*;
159 #[cfg(feature = "operator_scan")]
160 pub use rx_core_operator_scan::operator::*;
161 #[cfg(feature = "operator_share")]
162 pub use rx_core_operator_share::operator::*;
163 #[cfg(feature = "operator_skip")]
164 pub use rx_core_operator_skip::operator::*;
165 #[cfg(feature = "operator_start_with")]
166 pub use rx_core_operator_start_with::operator::*;
167 #[cfg(feature = "operator_subscribe_on")]
168 pub use rx_core_operator_subscribe_on::operator::*;
169 #[cfg(feature = "operator_switch_all")]
170 pub use rx_core_operator_switch_all::operator::*;
171 #[cfg(feature = "operator_switch_map")]
172 pub use rx_core_operator_switch_map::operator::*;
173 #[cfg(feature = "operator_take")]
174 pub use rx_core_operator_take::operator::*;
175 #[cfg(feature = "operator_tap")]
176 pub use rx_core_operator_tap::operator::*;
177 #[cfg(feature = "operator_tap_next")]
178 pub use rx_core_operator_tap_next::operator::*;
179 #[cfg(feature = "operator_with_latest_from")]
180 pub use rx_core_operator_with_latest_from::operator::*;
181}
182
183#[cfg(feature = "compose")]
184pub mod extension_compose {
185 #[cfg(feature = "operator_adsr")]
186 pub use rx_core_operator_adsr::extension_compose::*;
187 #[cfg(feature = "operator_buffer_count")]
188 pub use rx_core_operator_buffer_count::extension_compose::*;
189 #[cfg(feature = "operator_catch")]
190 pub use rx_core_operator_catch::extension_compose::*;
191 #[cfg(feature = "operator_composite")]
192 pub use rx_core_operator_composite::extension_compose::*;
193 #[cfg(feature = "operator_concat_all")]
194 pub use rx_core_operator_concat_all::extension_compose::*;
195 #[cfg(feature = "operator_concat_map")]
196 pub use rx_core_operator_concat_map::extension_compose::*;
197 #[cfg(feature = "operator_count")]
198 pub use rx_core_operator_count::extension_compose::*;
199 #[cfg(feature = "operator_delay")]
200 pub use rx_core_operator_delay::extension_compose::*;
201 #[cfg(feature = "operator_dematerialize")]
202 pub use rx_core_operator_dematerialize::extension_compose::*;
203 #[cfg(feature = "operator_element_at")]
204 pub use rx_core_operator_element_at::extension_compose::*;
205 #[cfg(feature = "operator_end_with")]
206 pub use rx_core_operator_end_with::extension_compose::*;
207 #[cfg(feature = "operator_enumerate")]
208 pub use rx_core_operator_enumerate::extension_compose::*;
209 #[cfg(feature = "operator_error_boundary")]
210 pub use rx_core_operator_error_boundary::extension_compose::*;
211 #[cfg(feature = "operator_exhaust_all")]
212 pub use rx_core_operator_exhaust_all::extension_compose::*;
213 #[cfg(feature = "operator_exhaust_map")]
214 pub use rx_core_operator_exhaust_map::extension_compose::*;
215 #[cfg(feature = "operator_fallback_when_silent")]
216 pub use rx_core_operator_fallback_when_silent::extension_compose::*;
217 #[cfg(feature = "operator_filter")]
218 pub use rx_core_operator_filter::extension_compose::*;
219 #[cfg(feature = "operator_filter_map")]
220 pub use rx_core_operator_filter_map::extension_compose::*;
221 #[cfg(feature = "operator_finalize")]
222 pub use rx_core_operator_finalize::extension_compose::*;
223 #[cfg(feature = "operator_find")]
224 pub use rx_core_operator_find::extension_compose::*;
225 #[cfg(feature = "operator_find_index")]
226 pub use rx_core_operator_find_index::extension_compose::*;
227 #[cfg(feature = "operator_first")]
228 pub use rx_core_operator_first::extension_compose::*;
229 #[cfg(feature = "operator_into_result")]
230 pub use rx_core_operator_into_result::extension_compose::*;
231 #[cfg(feature = "operator_is_empty")]
232 pub use rx_core_operator_is_empty::extension_compose::*;
233 #[cfg(feature = "operator_lift_option")]
234 pub use rx_core_operator_lift_option::extension_compose::*;
235 #[cfg(feature = "operator_lift_result")]
236 pub use rx_core_operator_lift_result::extension_compose::*;
237 #[cfg(feature = "operator_map")]
238 pub use rx_core_operator_map::extension_compose::*;
239 #[cfg(feature = "operator_map_error")]
240 pub use rx_core_operator_map_error::extension_compose::*;
241 #[cfg(feature = "operator_map_into")]
242 pub use rx_core_operator_map_into::extension_compose::*;
243 #[cfg(feature = "operator_map_never")]
244 pub use rx_core_operator_map_never::extension_compose::*;
245 #[cfg(feature = "operator_materialize")]
246 pub use rx_core_operator_materialize::extension_compose::*;
247 #[cfg(feature = "operator_merge_all")]
248 pub use rx_core_operator_merge_all::extension_compose::*;
249 #[cfg(feature = "operator_merge_map")]
250 pub use rx_core_operator_merge_map::extension_compose::*;
251 #[cfg(feature = "operator_observe_on")]
252 pub use rx_core_operator_observe_on::extension_compose::*;
253 #[cfg(feature = "operator_on_next")]
254 pub use rx_core_operator_on_next::extension_compose::*;
255 #[cfg(feature = "operator_on_subscribe")]
256 pub use rx_core_operator_on_subscribe::extension_compose::*;
257 #[cfg(feature = "operator_pairwise")]
258 pub use rx_core_operator_pairwise::extension_compose::*;
259 #[cfg(feature = "operator_reduce")]
260 pub use rx_core_operator_reduce::extension_compose::*;
261 #[cfg(feature = "operator_scan")]
262 pub use rx_core_operator_scan::extension_compose::*;
263 #[cfg(feature = "operator_skip")]
264 pub use rx_core_operator_skip::extension_compose::*;
265 #[cfg(feature = "operator_start_with")]
266 pub use rx_core_operator_start_with::extension_compose::*;
267 #[cfg(feature = "operator_switch_all")]
268 pub use rx_core_operator_switch_all::extension_compose::*;
269 #[cfg(feature = "operator_switch_map")]
270 pub use rx_core_operator_switch_map::extension_compose::*;
271 #[cfg(feature = "operator_take")]
272 pub use rx_core_operator_take::extension_compose::*;
273 #[cfg(feature = "operator_tap")]
274 pub use rx_core_operator_tap::extension_compose::*;
275 #[cfg(feature = "operator_tap_next")]
276 pub use rx_core_operator_tap_next::extension_compose::*;
277 #[cfg(feature = "operator_with_latest_from")]
278 pub use rx_core_operator_with_latest_from::extension_compose::*;
279}
280
281#[cfg(feature = "pipe")]
282pub mod extension_pipe {
283 #[cfg(feature = "operator_adsr")]
284 pub use rx_core_operator_adsr::extension_pipe::*;
285 #[cfg(feature = "operator_buffer_count")]
286 pub use rx_core_operator_buffer_count::extension_pipe::*;
287 #[cfg(feature = "operator_catch")]
288 pub use rx_core_operator_catch::extension_pipe::*;
289 #[cfg(feature = "operator_concat_all")]
290 pub use rx_core_operator_concat_all::extension_pipe::*;
291 #[cfg(feature = "operator_concat_map")]
292 pub use rx_core_operator_concat_map::extension_pipe::*;
293 #[cfg(feature = "operator_count")]
294 pub use rx_core_operator_count::extension_pipe::*;
295 #[cfg(feature = "operator_delay")]
296 pub use rx_core_operator_delay::extension_pipe::*;
297 #[cfg(feature = "operator_dematerialize")]
298 pub use rx_core_operator_dematerialize::extension_pipe::*;
299 #[cfg(feature = "operator_element_at")]
300 pub use rx_core_operator_element_at::extension_pipe::*;
301 #[cfg(feature = "operator_end_with")]
302 pub use rx_core_operator_end_with::extension_pipe::*;
303 #[cfg(feature = "operator_enumerate")]
304 pub use rx_core_operator_enumerate::extension_pipe::*;
305 #[cfg(feature = "operator_error_boundary")]
306 pub use rx_core_operator_error_boundary::extension_pipe::*;
307 #[cfg(feature = "operator_exhaust_all")]
308 pub use rx_core_operator_exhaust_all::extension_pipe::*;
309 #[cfg(feature = "operator_exhaust_map")]
310 pub use rx_core_operator_exhaust_map::extension_pipe::*;
311 #[cfg(feature = "operator_fallback_when_silent")]
312 pub use rx_core_operator_fallback_when_silent::extension_pipe::*;
313 #[cfg(feature = "operator_filter")]
314 pub use rx_core_operator_filter::extension_pipe::*;
315 #[cfg(feature = "operator_filter_map")]
316 pub use rx_core_operator_filter_map::extension_pipe::*;
317 #[cfg(feature = "operator_finalize")]
318 pub use rx_core_operator_finalize::extension_pipe::*;
319 #[cfg(feature = "operator_find")]
320 pub use rx_core_operator_find::extension_pipe::*;
321 #[cfg(feature = "operator_find_index")]
322 pub use rx_core_operator_find_index::extension_pipe::*;
323 #[cfg(feature = "operator_first")]
324 pub use rx_core_operator_first::extension_pipe::*;
325 #[cfg(feature = "operator_into_result")]
326 pub use rx_core_operator_into_result::extension_pipe::*;
327 #[cfg(feature = "operator_is_empty")]
328 pub use rx_core_operator_is_empty::extension_pipe::*;
329 #[cfg(feature = "operator_lift_option")]
330 pub use rx_core_operator_lift_option::extension_pipe::*;
331 #[cfg(feature = "operator_lift_result")]
332 pub use rx_core_operator_lift_result::extension_pipe::*;
333 #[cfg(feature = "operator_map")]
334 pub use rx_core_operator_map::extension_pipe::*;
335 #[cfg(feature = "operator_map_error")]
336 pub use rx_core_operator_map_error::extension_pipe::*;
337 #[cfg(feature = "operator_map_into")]
338 pub use rx_core_operator_map_into::extension_pipe::*;
339 #[cfg(feature = "operator_map_never")]
340 pub use rx_core_operator_map_never::extension_pipe::*;
341 #[cfg(feature = "operator_materialize")]
342 pub use rx_core_operator_materialize::extension_pipe::*;
343 #[cfg(feature = "operator_merge_all")]
344 pub use rx_core_operator_merge_all::extension_pipe::*;
345 #[cfg(feature = "operator_merge_map")]
346 pub use rx_core_operator_merge_map::extension_pipe::*;
347 #[cfg(feature = "operator_observe_on")]
348 pub use rx_core_operator_observe_on::extension_pipe::*;
349 #[cfg(feature = "operator_on_next")]
350 pub use rx_core_operator_on_next::extension_pipe::*;
351 #[cfg(feature = "operator_on_subscribe")]
352 pub use rx_core_operator_on_subscribe::extension_pipe::*;
353 #[cfg(feature = "operator_pairwise")]
354 pub use rx_core_operator_pairwise::extension_pipe::*;
355 #[cfg(feature = "operator_reduce")]
356 pub use rx_core_operator_reduce::extension_pipe::*;
357 #[cfg(feature = "operator_retry")]
358 pub use rx_core_operator_retry::extension_pipe::*;
359 #[cfg(feature = "operator_scan")]
360 pub use rx_core_operator_scan::extension_pipe::*;
361 #[cfg(feature = "operator_share")]
362 pub use rx_core_operator_share::extension_pipe::*;
363 #[cfg(feature = "operator_skip")]
364 pub use rx_core_operator_skip::extension_pipe::*;
365 #[cfg(feature = "operator_start_with")]
366 pub use rx_core_operator_start_with::extension_pipe::*;
367 #[cfg(feature = "operator_subscribe_on")]
368 pub use rx_core_operator_subscribe_on::extension_pipe::*;
369 #[cfg(feature = "operator_switch_all")]
370 pub use rx_core_operator_switch_all::extension_pipe::*;
371 #[cfg(feature = "operator_switch_map")]
372 pub use rx_core_operator_switch_map::extension_pipe::*;
373 #[cfg(feature = "operator_take")]
374 pub use rx_core_operator_take::extension_pipe::*;
375 #[cfg(feature = "operator_tap")]
376 pub use rx_core_operator_tap::extension_pipe::*;
377 #[cfg(feature = "operator_tap_next")]
378 pub use rx_core_operator_tap_next::extension_pipe::*;
379 #[cfg(feature = "operator_with_latest_from")]
380 pub use rx_core_operator_with_latest_from::extension_pipe::*;
381}
382
383pub mod observer {
384 #[cfg(feature = "observer_fn")]
385 pub use rx_core_observer_fn::observer::*;
386 #[cfg(feature = "observer_noop")]
387 pub use rx_core_observer_noop::observer::*;
388 #[cfg(feature = "observer_print")]
389 pub use rx_core_observer_print::observer::*;
390}
391
392pub mod scheduler {
393 #[cfg(feature = "scheduler_ticking")]
394 pub use rx_core_scheduler_ticking::scheduler::*;
395}
396
397pub mod subject {
398 #[cfg(feature = "subject_async")]
399 pub use rx_core_subject_async::subject::*;
400 #[cfg(feature = "subject_behavior")]
401 pub use rx_core_subject_behavior::subject::*;
402 #[cfg(feature = "subject_provenance")]
403 pub use rx_core_subject_provenance::subject::*;
404 #[cfg(feature = "subject_publish")]
405 pub use rx_core_subject_publish::subject::*;
406 #[cfg(feature = "subject_replay")]
407 pub use rx_core_subject_replay::subject::*;
408}
409
410pub mod prelude {
411 pub use rx_core_common::*;
412
413 pub use super::observable::*;
414 pub use super::observer::*;
415 pub use super::operator::*;
416 pub use super::subject::*;
417
418 #[cfg(feature = "observable_fn")]
419 pub use super::observable_fn::*;
420
421 #[cfg(feature = "compose")]
422 pub use super::extension_compose::*;
423
424 #[cfg(feature = "pipe")]
425 pub use super::extension_pipe::*;
426}