Bugfix.

Author: wbinarytree

.idea/misc.xml

@@ -19,7 +19,7 @@ public class AuthManager {
     private static final String TAG = "AuthManager";
     private SignUpResult result;
     private Observable<SignUpResult> observable = Observable.fromCallable(() -> result)
-            .delay(5000, TimeUnit.MILLISECONDS);
+            .delay(2000, TimeUnit.MILLISECONDS);
 
     public Observable<AuthResult.SignUpResult> signUp(SignUpAction action) {
         //检查用户名是否合法

.idea/modules.xml

@@ -70,6 +70,8 @@ protected void onStart() {
         Observable<SignUpEvent> click = RxView.clicks(mEmailSignInButton)
                 .map(ignore -> new SignUpEvent(mEmailView.getText()
                         .toString(), mPasswordView.getText().toString()));
+
+
         disposables.add(click.compose(translator.signUp)
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(authUiModel -> {

app/src/main/java/io/phoenix/demo/rxauthdemo/AuthManager.java

@@ -8,7 +8,7 @@
 import io.phoenix.demo.rxauthdemo.result.AuthResult.SignUpResult;
 import io.reactivex.Observable;
 import io.reactivex.ObservableTransformer;
-import io.reactivex.subjects.BehaviorSubject;
+import io.reactivex.subjects.PublishSubject;
 import io.reactivex.subjects.Subject;
 
 
@@ -18,9 +18,9 @@
 
 public class AuthTranslator {
     private AuthManager authManager;
-    private Subject<SignUpEvent> middle = BehaviorSubject.create();
-    private Observable<AuthUiModel> authUiModelObservable
-            = middle.map(event -> new SignUpAction(event.getUsername(), event.getPassword()))
+    private Subject<SignUpEvent> middle = PublishSubject.create();
+    private Observable<AuthUiModel> authUiModelObservable = middle
+            .map(event -> new SignUpAction(event.getUsername(), event.getPassword()))
             //使用FlatMap转向，进行注册
             .flatMap(action -> authManager.signUp(action)
                     //扫描结果
@@ -36,12 +36,14 @@ public class AuthTranslator {
                         }
                         //TODO Handle error
                         throw new IllegalArgumentException("Unknown Result");
-                    }).replay(1).autoConnect()
+                    })
                     //设置初始状态为loading。
                     .startWith(AuthUiModel.inProcess())
                     //设置错误状态为error，防止触发onError() 造成断流
-                    .onErrorReturn(error -> AuthUiModel.fail(true, true, error.getMessage())));
-    ;
+                    .onErrorReturn(error -> AuthUiModel.fail(true, true, error.getMessage())))
+            .replay(1)
+            .autoConnect();
+
     public final ObservableTransformer<SignUpEvent, AuthUiModel> signUp
             //上游是UiEvent，封装成对应的Action
             = observable -> {