| /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 | 160 const localState = globals.frontendLocalState; constant
167 localState.timeScale.timeToPx(selectedArea.startSec) +
170 localState.timeScale.deltaTimeToPx(
202 const localState = globals.frontendLocalState; constant
204 if (localState.hoveredNoteTimestamp !== -1) {
207 localState.timeScale,
208 localState.hoveredNoteTimestamp,
212 if (localState.hoveredLogsTimestamp !== -1) {
215 localState.timeScale,
216 localState.hoveredLogsTimestamp,
[all …]
|
| D | track_panel.ts | 293 const localState = globals.frontendLocalState; constant
298 const timeScale = localState.timeScale;
324 const localState = globals.frontendLocalState; constant
326 if (localState.hoveredNoteTimestamp !== -1) {
329 localState.timeScale,
330 localState.hoveredNoteTimestamp,
334 if (localState.hoveredLogsTimestamp !== -1) {
337 localState.timeScale,
338 localState.hoveredLogsTimestamp,
348 localState.timeScale,
[all …]
|
| /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)
196 state = self.localState.copy() if self.localState else dict()
198 self.localState = state
201 return self.localState and self.localState[name]
204 return self.localState and name in self.localState
211 def __init__(self, localState=None, tableTag=None, offsetSize=2): argument
214 self.localState = localState
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | Futures.java | 884 InCompletionOrderState<T> localState = state;
886 localState.recordOutputCancellation(interruptIfRunning);
899 InCompletionOrderState<T> localState = state;
900 if (localState != null) {
904 + localState.inputFutures.length
906 + localState.incompleteOutputCount.get()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Futures.java | 917 InCompletionOrderState<T> localState = state;
919 localState.recordOutputCancellation(interruptIfRunning);
932 InCompletionOrderState<T> localState = state;
933 if (localState != null) {
937 + localState.inputFutures.length
939 + localState.incompleteOutputCount.get()
|