simple_observable 0.3.0+2 simple_observable: ^0.3.0+2 copied to clipboard
Deprecated => Please use `debounce_throttle` instead.
// Example output:
// Tick : ||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
// Changed : ------- --- - - - - - - - - - - - - - - -- - - -- - - -- - -- -- - --- - - - - -- - - --- - -- - - - - - - - -
// Debounced: D D D D D D D D D D D D D D D D D D D D D D D D D D D
// Throttled: T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T
import 'dart:io';
import 'dart:async';
import 'dart:math';
import 'package:simple_observable/simple_observable.dart';
void main() async {
final debouncer =
Debouncer<String>(Duration(milliseconds: 300), onChanged: debounceTick);
final throttle =
Throttle<String>(Duration(milliseconds: 300), onChanged: throttleTick);
final random = Random();
void doChange() {
changeTick();
debouncer.value = '';
throttle.value = '';
}
startTicking();
// Change frequently at first to show difference between debounce/throttle.
for (int i = 0; i < 10; i++) {
await Future.delayed(Duration(milliseconds: 50));
doChange();
}
while (true) {
// Wait 50 to 550 milliseconds.
await Future.delayed(Duration(milliseconds: 50 + random.nextInt(500)));
doChange();
}
}
Timer startTicking() => Timer.periodic(Duration(milliseconds: 100), (timer) {
String changed = '', debounced = '', throttled = '';
ticks.forEach((tick) {
changed += tick.changed ? '-' : ' ';
debounced += tick.debounced ? 'D' : ' ';
throttled += tick.throttled ? 'T' : ' ';
});
if (Platform.isWindows) {
print(Process.runSync("cls", [], runInShell: true).stdout);
} else {
print(Process.runSync("clear", [], runInShell: true).stdout);
}
print('Tick : ${'|' * ticks.length}');
print('Changed : $changed');
print('Debounced: $debounced');
print('Throttled: $throttled');
if (ticks.length >= stdout.terminalColumns - 11) {
exit(0);
}
ticks.add(Tick());
});
/// For visual representation in the terminal.
class Tick {
bool changed = false;
bool debounced = false;
bool throttled = false;
}
final ticks = [Tick()];
void changeTick() => ticks.last.changed = true;
void debounceTick(String value) => ticks.last.debounced = true;
void throttleTick(String value) => ticks.last.throttled = true;