pyadav

public class FragmentHelper {
public static boolean isFragmentVisible(WeakReference<Fragment> fragment) {
        if (fragment!=null && fragment.get() != null && fragment.get().getActivity() != null &&
                fragment.get()
                .isVisible()
                && !fragment.get().isRemoving()) {
            return true;
        }
        return false;
    }

pyadav

package <Package Name>;

import android.content.Context;
import android.graphics.Typeface;
import android.text.TextUtils;

public class FontUtils {
    /**
     * Loads the desired font.
     *

pyadav

package <Package Name>;

import android.content.Context;
import android.content.SharedPreferences;
import android.preference.PreferenceManager;

import java.util.Map;
import java.util.Set;

public class PreferenceHelper {

pyadav

Observable.merge(Observable.from(getRawSelfPosts()), Observable.from(getRawFriendPosts()), Observable.from(getRawNearbyPosts(activity)))
  .distinct((post) -> post.getObjectId())
  .subscribeOn(Schedulers.io());

getRawPostsObs(activity).map((post) -> postToCardModel(post));

new RxList(getRawPostsObs(activity));

getPostsObs(activity).toList().toBlocking().single();

pyadav

 Observable.just("")
                .subscribeOn(Schedulers.immediate()).observeOn(Schedulers.io()).doOnSubscribe(() -> {
            //tv1.setText("fe");
        })
                .map(x -> {
                    InitVo initVo = qrHttp.init();

                    return initVo;
                })
                .map(initVo -> {

pyadav

public void doubleClickDetect(View view){
        Observable<Void> observable = RxView.clicks(view).share();
        observable.buffer(observable.debounce(200, TimeUnit.MILLISECONDS))
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<List<Void>>() {
                    @Override
                    public void call(List<Void> voids) {
                        if(voids.size() >= 2){
                        	//double click detected
                        }

pyadav

package com.example.rx_okhttp;

import com.squareup.okhttp.OkHttpClient;
import org.apache.http.*;
import org.apache.http.entity.InputStreamEntity;
import org.apache.http.message.BasicHeader;
import org.apache.http.message.BasicHttpResponse;
import rx.Observable;
import rx.Observer;
import rx.Scheduler;

pyadav

A small collection of rx-java resources

##Blog posts Intro to rxjava

• https://gist.github.com/staltz/868e7e9bc2a7b8c1f754
• http://joluet.github.io/blog/2014/07/07/rxjava-retrofit/
• http://www.node.mu/2014/07/02/using-retrofit-and-rxjava-to-interact-with-web-services-on-android/
• http://techblog.netflix.com/2013/02/rxjava-netflix-api.html
• http://nerds.weddingpartyapp.com/tech/2015/01/05/debouncedbuffer-used-in-rxbus-example/ EventBus + rxjava

pyadav

public class FacebookHomeProvider {
	protected final PublishSubject<FbPost> behaviorSubject;
	private Request request;

	public FacebookHomeProvider() {
		behaviorSubject = PublishSubject.create();
		behaviorSubject.subscribeOn(Schedulers.io());
	}

    /**

pyadav

//返回一个Obserable,侦听发给heat-sensor的信息
Observable<Double> observable = vertx.eventBus().
    <Double>consumer("heat-sensor").
    bodyStream().
    toObservable();

//这个obserable持续1秒钟，并对数据进行map reduce操作
observable.
    buffer(1, TimeUnit.SECONDS).
    map(samples -> samples.