Example of stream debouncing and throttling

transform_streams_example.dart

import 'dart:async';
import 'dart:math';
import 'package:stream_transform/stream_transform.dart';

StreamController<int> controller = StreamController<int>.broadcast();

void probe(int id, int delay) {
  print("Submitted(ID: $id; delay: $delay)");
  controller.add(id);
}

void invokeWithDelays(List<List<int>> delays) async {
  for (List<int> delay in delays) {
    await Future.delayed(
        Duration(milliseconds: delay[1]), () => probe(delay[0], delay[1]));
  }
}

void main(List<String> args) async {
  Random random = Random(0);

  final StreamTransformer<int, dynamic> debounce = StreamTransformer.fromBind(
          (s) => s.debounce(const Duration(milliseconds: 100)));

  final StreamTransformer<int, dynamic> debounceBuffer = StreamTransformer.fromBind(
          (s) => s.debounceBuffer(const Duration(milliseconds: 100)));

  final StreamTransformer<int, dynamic> throttle = StreamTransformer.fromBind(
          (s) => s.throttle(const Duration(milliseconds: 100)));


  controller.stream
      .transform(debounceBuffer)
      .listen((event) => print("debounceBuffer: $event"));

  controller.stream
      .transform(debounce)
      .listen((event) => print("debounce: $event"));

  controller.stream
      .transform(throttle)
      .listen((event) => print("throttle: $event"));

  final List<List<int>> delays = [];
  List<int>.generate(10, (i) => i + 1).forEach((id) {
    delays.add([id, 50 + random.nextInt(200)]);
  });

  await invokeWithDelays(delays);

  await controller.close();
}