mayuroks

/**
 * This is a contract between chat view and chat presenter.
 *
 */
public interface ChatContract {

    interface View extends BaseView<Presenter>, EventListener {

        void onMessageDelivered(ChatMessage chatMessage);
    }

mayuroks

/**
 * Closes the socket connection when app is in background and
 * connects to socket when the app is in foreground.
 */
public class AppLifeCycleObserver implements LifecycleObserver {

    private Context mContext;

    /**
     * Use this constructor to create a new AppLifeCycleObserver

mayuroks

public class BaseApplication extends Application {
    @Override
    public void onCreate() {
        super.onCreate();

        // Observer to detect if the app is in background or foreground.
        AppLifeCycleObserver lifeCycleObserver
                = new AppLifeCycleObserver(getApplicationContext());

        // Adding the above observer to process lifecycle

mayuroks

dependencies {
    implementation 'com.android.support:appcompat-v7:27.1.1'
    implementation 'androidx.constraintlayout:constraintlayout:1.1.2'

    // RxJava library and RxAndroid for Android specific bindings
    implementation 'io.reactivex.rxjava2:rxjava:2.2.0'
    implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'

    // Retrofit and OkHttp
    implementation 'com.squareup.retrofit2:retrofit:2.4.0'

mayuroks

{
  "userId": 1,
  "id": 1,
  "title": "delectus aut autem",
  "completed": false
}

mayuroks

public class Todo {

    String userId;
    int id;
    String title;
    boolean completed;

    public String getFormattedInfo() {
        StringBuilder builder = new StringBuilder();
        builder.append("Title: " + title + "\n\n");

mayuroks

public interface ApiService {

    @GET("/todos/1")
    Flowable<Todo> getFirstTodo();
}

mayuroks

public class HttpClient {
    private static final String API_BASE_URL = "https://jsonplaceholder.typicode.com/";

    private static Retrofit retrofit = new Retrofit.Builder()
            .baseUrl(API_BASE_URL)
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .addConverterFactory(GsonConverterFactory.create())
            .build();

    private static ApiService apiService = retrofit.create(ApiService.class);

mayuroks

public class SchedulerProvider {

    // UI thread
    public static Scheduler ui() {
        return AndroidSchedulers.mainThread();
    }

    // IO thread
    public static Scheduler io() {
        return Schedulers.io();

mayuroks

public class MainActivity extends AppCompatActivity {

    private ApiService apiService = HttpClient.getApiService();
    private TextView tvStatus, tvInfo;
    private Button btnHttpRequest, btnReset;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);