jemshit

import com.jakewharton.rx.ReplayingShare;
import com.jakewharton.rxrelay2.PublishRelay;
import com.jakewharton.rxrelay2.Relay;
import io.reactivex.Observable;

import java.util.concurrent.TimeUnit;

public class HotReactiveDataExpiration {

    // Problems to solve:

jemshit

import com.jakewharton.rx.ReplayingShare;
import com.jakewharton.rxrelay2.PublishRelay;
import com.jakewharton.rxrelay2.Relay;
import io.reactivex.Observable;

import java.util.concurrent.TimeUnit;

public class HotReactiveData {

    // Problems to solve:

jemshit

public class LazySingleton {

    private LazySingleton() {
    }

    private static volatile LazySingleton sInstance;

    public static LazySingleton getInstance() {

        if  (sInstance == null) {