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_debounce_time")]
94 pub use rx_core_operator_debounce_time::operator::*;
95 #[cfg(feature = "operator_delay")]
96 pub use rx_core_operator_delay::operator::*;
97 #[cfg(feature = "operator_dematerialize")]
98 pub use rx_core_operator_dematerialize::operator::*;
99 #[cfg(feature = "operator_element_at")]
100 pub use rx_core_operator_element_at::operator::*;
101 #[cfg(feature = "operator_end_with")]
102 pub use rx_core_operator_end_with::operator::*;
103 #[cfg(feature = "operator_enumerate")]
104 pub use rx_core_operator_enumerate::operator::*;
105 #[cfg(feature = "operator_error_boundary")]
106 pub use rx_core_operator_error_boundary::operator::*;
107 #[cfg(feature = "operator_exhaust_all")]
108 pub use rx_core_operator_exhaust_all::operator::*;
109 #[cfg(feature = "operator_exhaust_map")]
110 pub use rx_core_operator_exhaust_map::operator::*;
111 #[cfg(feature = "operator_fallback_when_silent")]
112 pub use rx_core_operator_fallback_when_silent::operator::*;
113 #[cfg(feature = "operator_filter")]
114 pub use rx_core_operator_filter::operator::*;
115 #[cfg(feature = "operator_filter_map")]
116 pub use rx_core_operator_filter_map::operator::*;
117 #[cfg(feature = "operator_finalize")]
118 pub use rx_core_operator_finalize::operator::*;
119 #[cfg(feature = "operator_find")]
120 pub use rx_core_operator_find::operator::*;
121 #[cfg(feature = "operator_find_index")]
122 pub use rx_core_operator_find_index::operator::*;
123 #[cfg(feature = "operator_first")]
124 pub use rx_core_operator_first::operator::*;
125 #[cfg(feature = "operator_identity")]
126 pub use rx_core_operator_identity::operator::*;
127 #[cfg(feature = "operator_into_result")]
128 pub use rx_core_operator_into_result::operator::*;
129 #[cfg(feature = "operator_is_empty")]
130 pub use rx_core_operator_is_empty::operator::*;
131 #[cfg(feature = "operator_lift_option")]
132 pub use rx_core_operator_lift_option::operator::*;
133 #[cfg(feature = "operator_lift_result")]
134 pub use rx_core_operator_lift_result::operator::*;
135 #[cfg(feature = "operator_map")]
136 pub use rx_core_operator_map::operator::*;
137 #[cfg(feature = "operator_map_error")]
138 pub use rx_core_operator_map_error::operator::*;
139 #[cfg(feature = "operator_map_into")]
140 pub use rx_core_operator_map_into::operator::*;
141 #[cfg(feature = "operator_map_never")]
142 pub use rx_core_operator_map_never::operator::*;
143 #[cfg(feature = "operator_materialize")]
144 pub use rx_core_operator_materialize::operator::*;
145 #[cfg(feature = "operator_merge_all")]
146 pub use rx_core_operator_merge_all::operator::*;
147 #[cfg(feature = "operator_merge_map")]
148 pub use rx_core_operator_merge_map::operator::*;
149 #[cfg(feature = "operator_observe_on")]
150 pub use rx_core_operator_observe_on::operator::*;
151 #[cfg(feature = "operator_on_next")]
152 pub use rx_core_operator_on_next::operator::*;
153 #[cfg(feature = "operator_on_subscribe")]
154 pub use rx_core_operator_on_subscribe::operator::*;
155 #[cfg(feature = "operator_pairwise")]
156 pub use rx_core_operator_pairwise::operator::*;
157 #[cfg(feature = "operator_reduce")]
158 pub use rx_core_operator_reduce::operator::*;
159 #[cfg(feature = "operator_retry")]
160 pub use rx_core_operator_retry::operator::*;
161 #[cfg(feature = "operator_scan")]
162 pub use rx_core_operator_scan::operator::*;
163 #[cfg(feature = "operator_share")]
164 pub use rx_core_operator_share::operator::*;
165 #[cfg(feature = "operator_skip")]
166 pub use rx_core_operator_skip::operator::*;
167 #[cfg(feature = "operator_start_with")]
168 pub use rx_core_operator_start_with::operator::*;
169 #[cfg(feature = "operator_subscribe_on")]
170 pub use rx_core_operator_subscribe_on::operator::*;
171 #[cfg(feature = "operator_switch_all")]
172 pub use rx_core_operator_switch_all::operator::*;
173 #[cfg(feature = "operator_switch_map")]
174 pub use rx_core_operator_switch_map::operator::*;
175 #[cfg(feature = "operator_take")]
176 pub use rx_core_operator_take::operator::*;
177 #[cfg(feature = "operator_tap")]
178 pub use rx_core_operator_tap::operator::*;
179 #[cfg(feature = "operator_tap_next")]
180 pub use rx_core_operator_tap_next::operator::*;
181 #[cfg(feature = "operator_throttle_time")]
182 pub use rx_core_operator_throttle_time::operator::*;
183 #[cfg(feature = "operator_with_latest_from")]
184 pub use rx_core_operator_with_latest_from::operator::*;
185}
186
187#[cfg(feature = "compose")]
188pub mod extension_compose {
189 #[cfg(feature = "operator_adsr")]
190 pub use rx_core_operator_adsr::extension_compose::*;
191 #[cfg(feature = "operator_buffer_count")]
192 pub use rx_core_operator_buffer_count::extension_compose::*;
193 #[cfg(feature = "operator_catch")]
194 pub use rx_core_operator_catch::extension_compose::*;
195 #[cfg(feature = "operator_composite")]
196 pub use rx_core_operator_composite::extension_compose::*;
197 #[cfg(feature = "operator_concat_all")]
198 pub use rx_core_operator_concat_all::extension_compose::*;
199 #[cfg(feature = "operator_concat_map")]
200 pub use rx_core_operator_concat_map::extension_compose::*;
201 #[cfg(feature = "operator_count")]
202 pub use rx_core_operator_count::extension_compose::*;
203 #[cfg(feature = "operator_debounce_time")]
204 pub use rx_core_operator_debounce_time::extension_compose::*;
205 #[cfg(feature = "operator_delay")]
206 pub use rx_core_operator_delay::extension_compose::*;
207 #[cfg(feature = "operator_dematerialize")]
208 pub use rx_core_operator_dematerialize::extension_compose::*;
209 #[cfg(feature = "operator_element_at")]
210 pub use rx_core_operator_element_at::extension_compose::*;
211 #[cfg(feature = "operator_end_with")]
212 pub use rx_core_operator_end_with::extension_compose::*;
213 #[cfg(feature = "operator_enumerate")]
214 pub use rx_core_operator_enumerate::extension_compose::*;
215 #[cfg(feature = "operator_error_boundary")]
216 pub use rx_core_operator_error_boundary::extension_compose::*;
217 #[cfg(feature = "operator_exhaust_all")]
218 pub use rx_core_operator_exhaust_all::extension_compose::*;
219 #[cfg(feature = "operator_exhaust_map")]
220 pub use rx_core_operator_exhaust_map::extension_compose::*;
221 #[cfg(feature = "operator_fallback_when_silent")]
222 pub use rx_core_operator_fallback_when_silent::extension_compose::*;
223 #[cfg(feature = "operator_filter")]
224 pub use rx_core_operator_filter::extension_compose::*;
225 #[cfg(feature = "operator_filter_map")]
226 pub use rx_core_operator_filter_map::extension_compose::*;
227 #[cfg(feature = "operator_finalize")]
228 pub use rx_core_operator_finalize::extension_compose::*;
229 #[cfg(feature = "operator_find")]
230 pub use rx_core_operator_find::extension_compose::*;
231 #[cfg(feature = "operator_find_index")]
232 pub use rx_core_operator_find_index::extension_compose::*;
233 #[cfg(feature = "operator_first")]
234 pub use rx_core_operator_first::extension_compose::*;
235 #[cfg(feature = "operator_into_result")]
236 pub use rx_core_operator_into_result::extension_compose::*;
237 #[cfg(feature = "operator_is_empty")]
238 pub use rx_core_operator_is_empty::extension_compose::*;
239 #[cfg(feature = "operator_lift_option")]
240 pub use rx_core_operator_lift_option::extension_compose::*;
241 #[cfg(feature = "operator_lift_result")]
242 pub use rx_core_operator_lift_result::extension_compose::*;
243 #[cfg(feature = "operator_map")]
244 pub use rx_core_operator_map::extension_compose::*;
245 #[cfg(feature = "operator_map_error")]
246 pub use rx_core_operator_map_error::extension_compose::*;
247 #[cfg(feature = "operator_map_into")]
248 pub use rx_core_operator_map_into::extension_compose::*;
249 #[cfg(feature = "operator_map_never")]
250 pub use rx_core_operator_map_never::extension_compose::*;
251 #[cfg(feature = "operator_materialize")]
252 pub use rx_core_operator_materialize::extension_compose::*;
253 #[cfg(feature = "operator_merge_all")]
254 pub use rx_core_operator_merge_all::extension_compose::*;
255 #[cfg(feature = "operator_merge_map")]
256 pub use rx_core_operator_merge_map::extension_compose::*;
257 #[cfg(feature = "operator_observe_on")]
258 pub use rx_core_operator_observe_on::extension_compose::*;
259 #[cfg(feature = "operator_on_next")]
260 pub use rx_core_operator_on_next::extension_compose::*;
261 #[cfg(feature = "operator_on_subscribe")]
262 pub use rx_core_operator_on_subscribe::extension_compose::*;
263 #[cfg(feature = "operator_pairwise")]
264 pub use rx_core_operator_pairwise::extension_compose::*;
265 #[cfg(feature = "operator_reduce")]
266 pub use rx_core_operator_reduce::extension_compose::*;
267 #[cfg(feature = "operator_scan")]
268 pub use rx_core_operator_scan::extension_compose::*;
269 #[cfg(feature = "operator_skip")]
270 pub use rx_core_operator_skip::extension_compose::*;
271 #[cfg(feature = "operator_start_with")]
272 pub use rx_core_operator_start_with::extension_compose::*;
273 #[cfg(feature = "operator_switch_all")]
274 pub use rx_core_operator_switch_all::extension_compose::*;
275 #[cfg(feature = "operator_switch_map")]
276 pub use rx_core_operator_switch_map::extension_compose::*;
277 #[cfg(feature = "operator_take")]
278 pub use rx_core_operator_take::extension_compose::*;
279 #[cfg(feature = "operator_tap")]
280 pub use rx_core_operator_tap::extension_compose::*;
281 #[cfg(feature = "operator_tap_next")]
282 pub use rx_core_operator_tap_next::extension_compose::*;
283 #[cfg(feature = "operator_throttle_time")]
284 pub use rx_core_operator_throttle_time::extension_compose::*;
285 #[cfg(feature = "operator_with_latest_from")]
286 pub use rx_core_operator_with_latest_from::extension_compose::*;
287}
288
289#[cfg(feature = "pipe")]
290pub mod extension_pipe {
291 #[cfg(feature = "operator_adsr")]
292 pub use rx_core_operator_adsr::extension_pipe::*;
293 #[cfg(feature = "operator_buffer_count")]
294 pub use rx_core_operator_buffer_count::extension_pipe::*;
295 #[cfg(feature = "operator_catch")]
296 pub use rx_core_operator_catch::extension_pipe::*;
297 #[cfg(feature = "operator_concat_all")]
298 pub use rx_core_operator_concat_all::extension_pipe::*;
299 #[cfg(feature = "operator_concat_map")]
300 pub use rx_core_operator_concat_map::extension_pipe::*;
301 #[cfg(feature = "operator_count")]
302 pub use rx_core_operator_count::extension_pipe::*;
303 #[cfg(feature = "operator_debounce_time")]
304 pub use rx_core_operator_debounce_time::extension_pipe::*;
305 #[cfg(feature = "operator_delay")]
306 pub use rx_core_operator_delay::extension_pipe::*;
307 #[cfg(feature = "operator_dematerialize")]
308 pub use rx_core_operator_dematerialize::extension_pipe::*;
309 #[cfg(feature = "operator_element_at")]
310 pub use rx_core_operator_element_at::extension_pipe::*;
311 #[cfg(feature = "operator_end_with")]
312 pub use rx_core_operator_end_with::extension_pipe::*;
313 #[cfg(feature = "operator_enumerate")]
314 pub use rx_core_operator_enumerate::extension_pipe::*;
315 #[cfg(feature = "operator_error_boundary")]
316 pub use rx_core_operator_error_boundary::extension_pipe::*;
317 #[cfg(feature = "operator_exhaust_all")]
318 pub use rx_core_operator_exhaust_all::extension_pipe::*;
319 #[cfg(feature = "operator_exhaust_map")]
320 pub use rx_core_operator_exhaust_map::extension_pipe::*;
321 #[cfg(feature = "operator_fallback_when_silent")]
322 pub use rx_core_operator_fallback_when_silent::extension_pipe::*;
323 #[cfg(feature = "operator_filter")]
324 pub use rx_core_operator_filter::extension_pipe::*;
325 #[cfg(feature = "operator_filter_map")]
326 pub use rx_core_operator_filter_map::extension_pipe::*;
327 #[cfg(feature = "operator_finalize")]
328 pub use rx_core_operator_finalize::extension_pipe::*;
329 #[cfg(feature = "operator_find")]
330 pub use rx_core_operator_find::extension_pipe::*;
331 #[cfg(feature = "operator_find_index")]
332 pub use rx_core_operator_find_index::extension_pipe::*;
333 #[cfg(feature = "operator_first")]
334 pub use rx_core_operator_first::extension_pipe::*;
335 #[cfg(feature = "operator_into_result")]
336 pub use rx_core_operator_into_result::extension_pipe::*;
337 #[cfg(feature = "operator_is_empty")]
338 pub use rx_core_operator_is_empty::extension_pipe::*;
339 #[cfg(feature = "operator_lift_option")]
340 pub use rx_core_operator_lift_option::extension_pipe::*;
341 #[cfg(feature = "operator_lift_result")]
342 pub use rx_core_operator_lift_result::extension_pipe::*;
343 #[cfg(feature = "operator_map")]
344 pub use rx_core_operator_map::extension_pipe::*;
345 #[cfg(feature = "operator_map_error")]
346 pub use rx_core_operator_map_error::extension_pipe::*;
347 #[cfg(feature = "operator_map_into")]
348 pub use rx_core_operator_map_into::extension_pipe::*;
349 #[cfg(feature = "operator_map_never")]
350 pub use rx_core_operator_map_never::extension_pipe::*;
351 #[cfg(feature = "operator_materialize")]
352 pub use rx_core_operator_materialize::extension_pipe::*;
353 #[cfg(feature = "operator_merge_all")]
354 pub use rx_core_operator_merge_all::extension_pipe::*;
355 #[cfg(feature = "operator_merge_map")]
356 pub use rx_core_operator_merge_map::extension_pipe::*;
357 #[cfg(feature = "operator_observe_on")]
358 pub use rx_core_operator_observe_on::extension_pipe::*;
359 #[cfg(feature = "operator_on_next")]
360 pub use rx_core_operator_on_next::extension_pipe::*;
361 #[cfg(feature = "operator_on_subscribe")]
362 pub use rx_core_operator_on_subscribe::extension_pipe::*;
363 #[cfg(feature = "operator_pairwise")]
364 pub use rx_core_operator_pairwise::extension_pipe::*;
365 #[cfg(feature = "operator_reduce")]
366 pub use rx_core_operator_reduce::extension_pipe::*;
367 #[cfg(feature = "operator_retry")]
368 pub use rx_core_operator_retry::extension_pipe::*;
369 #[cfg(feature = "operator_scan")]
370 pub use rx_core_operator_scan::extension_pipe::*;
371 #[cfg(feature = "operator_share")]
372 pub use rx_core_operator_share::extension_pipe::*;
373 #[cfg(feature = "operator_skip")]
374 pub use rx_core_operator_skip::extension_pipe::*;
375 #[cfg(feature = "operator_start_with")]
376 pub use rx_core_operator_start_with::extension_pipe::*;
377 #[cfg(feature = "operator_subscribe_on")]
378 pub use rx_core_operator_subscribe_on::extension_pipe::*;
379 #[cfg(feature = "operator_switch_all")]
380 pub use rx_core_operator_switch_all::extension_pipe::*;
381 #[cfg(feature = "operator_switch_map")]
382 pub use rx_core_operator_switch_map::extension_pipe::*;
383 #[cfg(feature = "operator_take")]
384 pub use rx_core_operator_take::extension_pipe::*;
385 #[cfg(feature = "operator_tap")]
386 pub use rx_core_operator_tap::extension_pipe::*;
387 #[cfg(feature = "operator_tap_next")]
388 pub use rx_core_operator_tap_next::extension_pipe::*;
389 #[cfg(feature = "operator_throttle_time")]
390 pub use rx_core_operator_throttle_time::extension_pipe::*;
391 #[cfg(feature = "operator_with_latest_from")]
392 pub use rx_core_operator_with_latest_from::extension_pipe::*;
393}
394
395pub mod observer {
396 #[cfg(feature = "observer_fn")]
397 pub use rx_core_observer_fn::observer::*;
398 #[cfg(feature = "observer_noop")]
399 pub use rx_core_observer_noop::observer::*;
400 #[cfg(feature = "observer_print")]
401 pub use rx_core_observer_print::observer::*;
402}
403
404pub mod scheduler {
405 #[cfg(feature = "scheduler_ticking")]
406 pub use rx_core_scheduler_ticking::scheduler::*;
407}
408
409pub mod subject {
410 #[cfg(feature = "subject_async")]
411 pub use rx_core_subject_async::subject::*;
412 #[cfg(feature = "subject_behavior")]
413 pub use rx_core_subject_behavior::subject::*;
414 #[cfg(feature = "subject_provenance")]
415 pub use rx_core_subject_provenance::subject::*;
416 #[cfg(feature = "subject_publish")]
417 pub use rx_core_subject_publish::subject::*;
418 #[cfg(feature = "subject_replay")]
419 pub use rx_core_subject_replay::subject::*;
420}
421
422pub mod prelude {
423 pub use rx_core_common::*;
424
425 pub use super::observable::*;
426 pub use super::observer::*;
427 pub use super::operator::*;
428 pub use super::subject::*;
429
430 #[cfg(feature = "observable_fn")]
431 pub use super::observable_fn::*;
432
433 #[cfg(feature = "compose")]
434 pub use super::extension_compose::*;
435
436 #[cfg(feature = "pipe")]
437 pub use super::extension_pipe::*;
438}