msb-public
/
FairEmail
mirror of https://github.com/M66B/FairEmail.git
1
0
Code Issues Projects Releases Wiki Activity

Revert "You're being watched"

Browse Source 
This reverts commit d303a859a8.
pull/207/head
M66B 3 years ago
parent d423b4351e
commit 21612c97e5
1 changed files with 23 additions and 38 deletions
Show Stats Download Patch File Download Diff File

61
app/src/main/java/eu/faircode/email/SimpleTask.java
Unescape View File

@ -144,15 +144,6 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
} }
} }
LifecycleObserver watcher = new LifecycleObserver() {
@OnLifecycleEvent(Lifecycle.Event.ON_DESTROY)
public void onDestroy() {
EntityLog.log(context, EntityLog.Type.Debug, "Cancelling task=" + name);
cancel(context);
owner.getLifecycle().removeObserver(this);
}
};
future = getExecutor(context).submit(new Runnable() { future = getExecutor(context).submit(new Runnable() {
private Object data; private Object data;
private long elapsed; private long elapsed;
@ -190,34 +181,30 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
if (state.equals(Lifecycle.State.DESTROYED)) { if (state.equals(Lifecycle.State.DESTROYED)) {
// No delivery // No delivery
cleanup(context); cleanup(context);
} else if (state.isAtLeast(Lifecycle.State.RESUMED)) {
// Inline delivery
Log.i("Deliver task " + name + " state=" + state + " elapse=" + elapsed + " ms");
deliver();
cleanup(context);
} else { } else {
owner.getLifecycle().removeObserver(watcher); Log.i("Deferring task " + name + " state=" + state);
owner.getLifecycle().addObserver(new LifecycleObserver() {
if (state.isAtLeast(Lifecycle.State.RESUMED)) { @OnLifecycleEvent(Lifecycle.Event.ON_ANY)
// Inline delivery public void onAny() {
Log.i("Deliver task " + name + " state=" + state + " elapse=" + elapsed + " ms"); state = owner.getLifecycle().getCurrentState();
deliver(); if (state.equals(Lifecycle.State.DESTROYED)) {
cleanup(context); Log.i("Destroyed task " + name);
} else { owner.getLifecycle().removeObserver(this);
Log.i("Deferring task " + name + " state=" + state); cleanup(context);
owner.getLifecycle().addObserver(new LifecycleObserver() { } else if (state.isAtLeast(Lifecycle.State.RESUMED)) {
@OnLifecycleEvent(Lifecycle.Event.ON_ANY) Log.i("Deferred delivery task " + name);
public void onAny() { owner.getLifecycle().removeObserver(this);
state = owner.getLifecycle().getCurrentState(); deliver();
if (state.equals(Lifecycle.State.DESTROYED)) { cleanup(context);
Log.i("Destroyed task " + name); } else
owner.getLifecycle().removeObserver(this); Log.i("Deferring task " + name + " state=" + state);
cleanup(context); }
} else if (state.isAtLeast(Lifecycle.State.RESUMED)) { });
Log.i("Deferred delivery task " + name);
owner.getLifecycle().removeObserver(this);
deliver();
cleanup(context);
} else
Log.i("Deferring task " + name + " state=" + state);
}
});
}
} }
} }
@ -262,8 +249,6 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
} }
}); });
owner.getLifecycle().addObserver(watcher);
updateTaskCount(context); updateTaskCount(context);
} }

Write Preview
Loading…
Cancel
Save