I have implement a validate function, sample code are as below: public class TestObject { LocalDateTime d1; LocalDateTime d2; //getters, setters } public class ErrorResult { String errorMsg; public ErrorResult(String errorMsg){ this.errorMsg = errorMsg; } } public Observable<ErrorResult> validate(TestObject testObject){ // implementation section } For the implementation section, I have tried to use Observable.fromCallable() and… Read More RxJava fromCallable() and defer() difference in behaviour

I have implement a validate function, sample code are as below: public class TestObject { LocalDateTime d1; LocalDateTime d2; //getters, setters } public class ErrorResult { String errorMsg; public ErrorResult(String errorMsg){ this.errorMsg = errorMsg; } } public Observable<ErrorResult> validate(TestObject testObject){ // implementation section } For the implementation section, I have tried to use Observable.fromCallable() and… Read More RxJava fromCallable() and defer() difference in behaviour