startPolicy method

void startPolicy(FlushPolicy policy)

Implementation

void startPolicy(FlushPolicy policy) {
  policy.start();
  final observer = policy.addListener((shouldFlush) {
    if (shouldFlush) {
      _onFlush();
    }
  });

  _observers.add(observer);
}