Searched refs:localState (Results 1 – 15 of 15) sorted by relevance
117 auto localState = state; in window_with_time_observer() local120 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 …]
111 auto localState = state; in window_toggle_observer() local117 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 …]
125 auto localState = state; in buffer_with_time_observer() local128 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 …]
97 auto localState = state; in sample_with_time_observer() local100 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 …]
109 auto localState = state; in timeout_observer() local112 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 …]
112 auto localState = state; in window_with_time_or_count_observer() local115 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 …]
110 auto localState = state; in buffer_with_time_or_count_observer() local113 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 …]
102 auto localState = state; in debounce_observer() local105 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 …]
98 auto localState = state; in delay_observer() local101 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 …]
70 auto localState = state; in on_connect() local74 [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()
116 const localState = globals.frontendLocalState; constant118 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,
227 const localState = globals.frontendLocalState; constant229 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,
115 def __init__(self, data, localState=None, offset=0, tableTag=None): argument119 self.localState = localState129 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 = state215 return self.localState and self.localState[name]218 return self.localState and name in self.localState225 def __init__(self, localState=None, tableTag=None): argument228 self.localState = localState[all …]
META-INF/MANIFEST.MF META-INF/ META-INF/maven/ META- ...
META-INF/ META-INF/MANIFEST.MF META-INF/services/ META- ...