geronimo-iia /
async-rx
| Total Complexity | 0 |
| Total Lines | 153 |
| Duplicated Lines | 0 % |
| Changes | 0 | ||
| 1 | """async-rx definition.""" |
||
| 2 | from pkg_resources import DistributionNotFound, get_distribution |
||
| 3 | |||
| 4 | from .protocol import ( |
||
| 5 | Subscription, |
||
| 6 | NextHandler, |
||
| 7 | CompleteHandler, |
||
| 8 | ErrorHandler, |
||
| 9 | Observable, |
||
| 10 | Observer, |
||
| 11 | Collector, |
||
| 12 | Subscribe, |
||
| 13 | Subject, |
||
| 14 | ConnectHandler, |
||
| 15 | RefCountHandler, |
||
| 16 | ConnectableObservable, |
||
| 17 | ObservableFactory, |
||
| 18 | SubjectEventHandler, |
||
| 19 | SubjectHandler, |
||
| 20 | ConnectableObservableEventHandler, |
||
| 21 | ConnectableObservableHandler, |
||
| 22 | PredicateOperator, |
||
| 23 | AccumulatorOperator, |
||
| 24 | SubjectFactory, |
||
| 25 | rx_observer, |
||
| 26 | rx_observer_from, |
||
| 27 | rx_collector, |
||
| 28 | ) |
||
| 29 | |||
| 30 | from .subject import rx_subject, rx_subject_replay, rx_subject_behavior, rx_subject_from |
||
| 31 | |||
| 32 | from .multicast import rx_publish, rx_publish_replay, rx_publish_behavior |
||
| 33 | from .observable import ( |
||
| 34 | rx_create, |
||
| 35 | rx_defer, |
||
| 36 | rx_distinct, |
||
| 37 | rx_empty, |
||
| 38 | rx_filter, |
||
| 39 | rx_first, |
||
| 40 | rx_forward, |
||
| 41 | rx_from, |
||
| 42 | rx_last, |
||
| 43 | rx_of, |
||
| 44 | rx_range, |
||
| 45 | rx_skip, |
||
| 46 | rx_take, |
||
| 47 | rx_throw, |
||
| 48 | rx_reduce, |
||
| 49 | rx_count, |
||
| 50 | rx_max, |
||
| 51 | rx_min, |
||
| 52 | rx_sum, |
||
| 53 | rx_avg, |
||
| 54 | rx_buffer, |
||
| 55 | rx_window, |
||
| 56 | rx_merge, |
||
| 57 | rx_concat, |
||
| 58 | rx_zip, |
||
| 59 | rx_amb, |
||
| 60 | rx_map, |
||
| 61 | rx_merge_map, |
||
| 62 | rx_group_by, |
||
| 63 | rx_sample, |
||
| 64 | rx_throttle, |
||
| 65 | rx_delay, |
||
| 66 | rx_debounce, |
||
| 67 | rx_dict, |
||
| 68 | rx_list, |
||
| 69 | rx_repeat, |
||
| 70 | rx_repeat_series, |
||
| 71 | ) |
||
| 72 | |||
| 73 | from .protocol.definition import __all__ as _def_all |
||
| 74 | from .protocol.observer import __all__ as _obs_all |
||
| 75 | |||
| 76 | __all__ = [ |
||
| 77 | "Subscription", |
||
| 78 | "NextHandler", |
||
| 79 | "CompleteHandler", |
||
| 80 | "ErrorHandler", |
||
| 81 | "Observable", |
||
| 82 | "Observer", |
||
| 83 | "Collector", |
||
| 84 | "Subscribe", |
||
| 85 | "Subject", |
||
| 86 | "ConnectHandler", |
||
| 87 | "RefCountHandler", |
||
| 88 | "ConnectableObservable", |
||
| 89 | "ObservableFactory", |
||
| 90 | "SubjectEventHandler", |
||
| 91 | "SubjectHandler", |
||
| 92 | "ConnectableObservableEventHandler", |
||
| 93 | "ConnectableObservableHandler", |
||
| 94 | "PredicateOperator", |
||
| 95 | "AccumulatorOperator", |
||
| 96 | "SubjectFactory", |
||
| 97 | "rx_observer", |
||
| 98 | "rx_observer_from", |
||
| 99 | "rx_collector", |
||
| 100 | # from observable |
||
| 101 | "rx_create", |
||
| 102 | "rx_defer", |
||
| 103 | "rx_distinct", |
||
| 104 | "rx_empty", |
||
| 105 | "rx_filter", |
||
| 106 | "rx_first", |
||
| 107 | "rx_forward", |
||
| 108 | "rx_from", |
||
| 109 | "rx_last", |
||
| 110 | "rx_of", |
||
| 111 | "rx_range", |
||
| 112 | "rx_skip", |
||
| 113 | "rx_take", |
||
| 114 | "rx_throw", |
||
| 115 | "rx_reduce", |
||
| 116 | "rx_count", |
||
| 117 | "rx_max", |
||
| 118 | "rx_min", |
||
| 119 | "rx_sum", |
||
| 120 | "rx_avg", |
||
| 121 | "rx_buffer", |
||
| 122 | "rx_window", |
||
| 123 | "rx_merge", |
||
| 124 | "rx_concat", |
||
| 125 | "rx_zip", |
||
| 126 | "rx_amb", |
||
| 127 | "rx_map", |
||
| 128 | "rx_merge_map", |
||
| 129 | "rx_group_by", |
||
| 130 | "rx_sample", |
||
| 131 | "rx_throttle", |
||
| 132 | "rx_delay", |
||
| 133 | "rx_debounce", |
||
| 134 | "rx_dict", |
||
| 135 | "rx_list", |
||
| 136 | "rx_repeat", |
||
| 137 | "rx_repeat_series", |
||
| 138 | # subject |
||
| 139 | "rx_subject", |
||
| 140 | "rx_subject_from", |
||
| 141 | "rx_subject_replay", |
||
| 142 | "rx_subject_behavior", |
||
| 143 | # multicast |
||
| 144 | "rx_publish", |
||
| 145 | "rx_publish_replay", |
||
| 146 | "rx_publish_behavior", |
||
| 147 | ] |
||
| 148 | |||
| 149 | try: |
||
| 150 | __version__ = get_distribution('async_rx').version |
||
| 151 | except DistributionNotFound: # pragma: no cover |
||
| 152 | __version__ = '(local)' |
||
| 153 |
