heyhey1028 · November 11, 2022 03:25
diff --git a/README.md b/README.md
diff --git a/stream_extension.dart b/stream_extension.dart
 extension StreamEx<T> on Stream<T> {
  Stream<T> onlyNotify(
    bool Function(T? previousEvent, T currentEvent) test,
  ) async* {
    T? previousEvent;
    await for (final event in this) {
      if (test(previousEvent, event)) {
        yield event;
      }
      previousEvent = event;
    }
  }
 }
	extension StreamEx<T> on Stream<T> {
	Stream<T> onlyNotify(
	bool Function(T? previousEvent, T currentEvent) test,
	) async* {
	T? previousEvent;
	await for (final event in this) {
	if (test(previousEvent, event)) {
	yield event;
	}
	previousEvent = event;
	}
	}
	}