| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-window_time.hpp | 117 auto localState = state; in window_with_time_observer() local
120 localState->cs.unsubscribe(); in window_with_time_observer()
121 localState->dest.unsubscribe(); in window_with_time_observer()
122 localState->worker.unsubscribe(); in window_with_time_observer()
125 [&](){return localState->coordinator.act(disposer);}, in window_with_time_observer()
126 localState->dest); in window_with_time_observer()
131 localState->dest.add([=](){ in window_with_time_observer()
132 localState->worker.schedule(selectedDisposer.get()); in window_with_time_observer()
134 localState->cs.add([=](){ in window_with_time_observer()
135 localState->worker.schedule(selectedDisposer.get()); in window_with_time_observer()
[all …]
|
| D | rx-window_toggle.hpp | 111 auto localState = state; in window_toggle_observer() local
117 auto innerscope = localState->dest.add(innercs); in window_toggle_observer()
120 localState->dest.remove(innerscope); in window_toggle_observer()
123 localState->dest.add(localState->cs); in window_toggle_observer()
126 [&](){return localState->coordinator.in(localState->openings);}, in window_toggle_observer()
127 localState->dest); in window_toggle_observer()
136 localState->dest, in window_toggle_observer()
139 [localState](const openings_value_type& ov) { in window_toggle_observer()
140 auto closer = localState->closingSelector(ov); in window_toggle_observer()
142 … auto it = localState->subj.insert(localState->subj.end(), rxcpp::subjects::subject<T>()); in window_toggle_observer()
[all …]
|
| D | rx-buffer_time.hpp | 125 auto localState = state; in buffer_with_time_observer() local
128 localState->cs.unsubscribe(); in buffer_with_time_observer()
129 localState->dest.unsubscribe(); in buffer_with_time_observer()
130 localState->worker.unsubscribe(); in buffer_with_time_observer()
133 [&](){return localState->coordinator.act(disposer);}, in buffer_with_time_observer()
134 localState->dest); in buffer_with_time_observer()
139 localState->dest.add([=](){ in buffer_with_time_observer()
140 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_observer()
142 localState->cs.add([=](){ in buffer_with_time_observer()
143 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_observer()
[all …]
|
| D | rx-sample_time.hpp | 97 auto localState = state; in sample_with_time_observer() local
100 localState->cs.unsubscribe(); in sample_with_time_observer()
101 localState->dest.unsubscribe(); in sample_with_time_observer()
102 localState->worker.unsubscribe(); in sample_with_time_observer()
105 [&](){ return localState->coordinator.act(disposer); }, in sample_with_time_observer()
106 localState->dest); in sample_with_time_observer()
111 localState->dest.add([=](){ in sample_with_time_observer()
112 localState->worker.schedule(selectedDisposer.get()); in sample_with_time_observer()
114 localState->cs.add([=](){ in sample_with_time_observer()
115 localState->worker.schedule(selectedDisposer.get()); in sample_with_time_observer()
[all …]
|
| D | rx-timeout.hpp | 109 auto localState = state; in timeout_observer() local
112 localState->cs.unsubscribe(); in timeout_observer()
113 localState->dest.unsubscribe(); in timeout_observer()
114 localState->worker.unsubscribe(); in timeout_observer()
117 [&](){ return localState->coordinator.act(disposer); }, in timeout_observer()
118 localState->dest); in timeout_observer()
123 localState->dest.add([=](){ in timeout_observer()
124 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()
126 localState->cs.add([=](){ in timeout_observer()
127 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()
[all …]
|
| D | rx-buffer_time_count.hpp | 110 auto localState = state; in buffer_with_time_or_count_observer() local
113 localState->cs.unsubscribe(); in buffer_with_time_or_count_observer()
114 localState->dest.unsubscribe(); in buffer_with_time_or_count_observer()
115 localState->worker.unsubscribe(); in buffer_with_time_or_count_observer()
118 [&](){return localState->coordinator.act(disposer);}, in buffer_with_time_or_count_observer()
119 localState->dest); in buffer_with_time_or_count_observer()
124 localState->dest.add([=](){ in buffer_with_time_or_count_observer()
125 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_or_count_observer()
127 localState->cs.add([=](){ in buffer_with_time_or_count_observer()
128 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_or_count_observer()
[all …]
|
| D | rx-window_time_count.hpp | 112 auto localState = state; in window_with_time_or_count_observer() local
115 localState->cs.unsubscribe(); in window_with_time_or_count_observer()
116 localState->dest.unsubscribe(); in window_with_time_or_count_observer()
117 localState->worker.unsubscribe(); in window_with_time_or_count_observer()
120 [&](){return localState->coordinator.act(disposer);}, in window_with_time_or_count_observer()
121 localState->dest); in window_with_time_or_count_observer()
126 localState->dest.add([=](){ in window_with_time_or_count_observer()
127 localState->worker.schedule(selectedDisposer.get()); in window_with_time_or_count_observer()
129 localState->cs.add([=](){ in window_with_time_or_count_observer()
130 localState->worker.schedule(selectedDisposer.get()); in window_with_time_or_count_observer()
[all …]
|
| D | rx-debounce.hpp | 102 auto localState = state; in debounce_observer() local
105 localState->cs.unsubscribe(); in debounce_observer()
106 localState->dest.unsubscribe(); in debounce_observer()
107 localState->worker.unsubscribe(); in debounce_observer()
110 [&](){ return localState->coordinator.act(disposer); }, in debounce_observer()
111 localState->dest); in debounce_observer()
116 localState->dest.add([=](){ in debounce_observer()
117 localState->worker.schedule(selectedDisposer.get()); in debounce_observer()
119 localState->cs.add([=](){ in debounce_observer()
120 localState->worker.schedule(selectedDisposer.get()); in debounce_observer()
[all …]
|
| D | rx-delay.hpp | 98 auto localState = state; in delay_observer() local
101 localState->cs.unsubscribe(); in delay_observer()
102 localState->dest.unsubscribe(); in delay_observer()
103 localState->worker.unsubscribe(); in delay_observer()
106 [&](){return localState->coordinator.act(disposer);}, in delay_observer()
107 localState->dest); in delay_observer()
112 localState->dest.add([=](){ in delay_observer()
113 localState->worker.schedule(selectedDisposer.get()); in delay_observer()
115 localState->cs.add([=](){ in delay_observer()
116 …localState->worker.schedule(localState->worker.now() + localState->period, selectedDisposer.get()); in delay_observer()
[all …]
|
| D | rx-multicast.hpp | 70 auto localState = state; in on_connect() local
74 [destination, localState](){ in on_connect()
75 if (!localState->connection.empty()) { in on_connect()
76 destination.remove(localState->connection.get()); in on_connect()
77 localState->connection.reset(); in on_connect()
|
| /external/perfetto/ui/src/frontend/ |
| D | track_group_panel.ts | 116 const localState = globals.frontendLocalState; constant
118 if (localState.showNotePreview) {
120 localState.timeScale,
121 localState.hoveredTimestamp,
126 if (localState.showTimeSelectPreview) {
128 localState.timeScale,
129 localState.hoveredTimestamp,
137 localState.timeScale,
144 localState.timeScale,
154 localState.timeScale,
|
| D | track_panel.ts | 227 const localState = globals.frontendLocalState; constant
229 if (localState.showNotePreview) {
231 localState.timeScale,
232 localState.hoveredTimestamp,
237 if (localState.showTimeSelectPreview) {
239 localState.timeScale,
240 localState.hoveredTimestamp,
249 localState.timeScale,
256 localState.timeScale,
266 localState.timeScale,
|
| /external/fonttools/Lib/fontTools/ttLib/tables/ |
| D | otBase.py | 115 def __init__(self, data, localState=None, offset=0, tableTag=None): argument
119 self.localState = localState
129 other = self.__class__(self.data, self.localState, self.offset, self.tableTag)
135 return self.__class__(self.data, self.localState, offset, self.tableTag)
210 state = self.localState.copy() if self.localState else dict()
212 self.localState = state
215 return self.localState and self.localState[name]
218 return self.localState and name in self.localState
225 def __init__(self, localState=None, tableTag=None): argument
228 self.localState = localState
[all …]
|