diff --git a/README.md b/README.md index cd9e825..a07896e 100644 --- a/README.md +++ b/README.md @@ -31,7 +31,7 @@ dependencies { ### Spread Some :heart: [![GitHub stars](https://img.shields.io/github/stars/aritraroy/PatternLockView.svg?style=social&label=Star)](https://github.com/aritraroy) [![GitHub followers](https://img.shields.io/github/followers/aritraroy.svg?style=social&label=Follow)](https://github.com/aritraroy) -[![Twitter Follow](https://img.shields.io/twitter/follow/aritraroy93.svg?style=social)](https://twitter.com/aritraroy93) +[![Twitter Follow](https://img.shields.io/twitter/follow/aritraroy.svg?style=social)](https://twitter.com/aritraroy) # Usage @@ -175,7 +175,8 @@ Android & Backend Developer. Blogger. Designer. Fitness Enthusiast. - + + # License diff --git a/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewCompleteObservable.java b/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewCompleteObservable.java index 26ae6f3..85fab78 100644 --- a/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewCompleteObservable.java +++ b/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewCompleteObservable.java @@ -22,17 +22,17 @@ public PatternLockViewCompleteObservable(PatternLockView patternLockView, boolea @Override protected void subscribeListener(Observer observer) { - subscribeListener(observer); - if (mEmitInitialValue) { - observer.onNext(new PatternLockCompleteEvent(mPatternLockView.getPattern())); - } + InternalListener internalListener = new InternalListener(mPatternLockView, observer); + observer.onSubscribe(internalListener); + mPatternLockView.addPatternLockListener(internalListener); } @Override protected void subscribeActual(Observer observer) { - InternalListener internalListener = new InternalListener(mPatternLockView, observer); - observer.onSubscribe(internalListener); - mPatternLockView.addPatternLockListener(internalListener); + subscribeListener(observer); + if (mEmitInitialValue) { + observer.onNext(new PatternLockCompleteEvent(mPatternLockView.getPattern())); + } } private static final class InternalListener extends MainThreadDisposable diff --git a/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewProgressObservable.java b/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewProgressObservable.java index bd1e598..8597ab8 100644 --- a/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewProgressObservable.java +++ b/patternlockview-reactive/src/main/java/com/andrognito/rxpatternlockview/observables/PatternLockViewProgressObservable.java @@ -22,17 +22,17 @@ public PatternLockViewProgressObservable(PatternLockView patternLockView, boolea @Override protected void subscribeListener(Observer observer) { - subscribeListener(observer); - if (mEmitInitialValue) { - observer.onNext(new PatternLockProgressEvent(mPatternLockView.getPattern())); - } + InternalListener internalListener = new InternalListener(mPatternLockView, observer); + observer.onSubscribe(internalListener); + mPatternLockView.addPatternLockListener(internalListener); } @Override protected void subscribeActual(Observer observer) { - InternalListener internalListener = new InternalListener(mPatternLockView, observer); - observer.onSubscribe(internalListener); - mPatternLockView.addPatternLockListener(internalListener); + subscribeListener(observer); + if (mEmitInitialValue) { + observer.onNext(new PatternLockProgressEvent(mPatternLockView.getPattern())); + } } private static final class InternalListener extends MainThreadDisposable