Fix def value

NaikSoftware · NaikSoftware · commit 2bf78e05c2e8 · 2018-04-03T21:02:02.000+03:00
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/AbstractConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/AbstractConnectionProvider.java
@@ -33,7 +33,7 @@ abstract class AbstractConnectionProvider implements ConnectionProvider {
     AbstractConnectionProvider() {
         mLifecycleStream = PublishSubject.create();
         mMessagesStream = PublishSubject.create();
-        mConnectionStream = BehaviorSubject.create();
+        mConnectionStream = BehaviorSubject.createDefault(false);
     }
 
     @NonNull

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ abstract class AbstractConnectionProvider implements ConnectionProvider {`
`33`	`33`	`AbstractConnectionProvider() {`
`34`	`34`	`mLifecycleStream = PublishSubject.create();`
`35`	`35`	`mMessagesStream = PublishSubject.create();`
`36`		`- mConnectionStream = BehaviorSubject.create();`
	`36`	`+ mConnectionStream = BehaviorSubject.createDefault(false);`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`@NonNull`