// Path: easy-http-library-rx/src/main/java/com/yang/easyhttprx/RxEasyHttp.java
// public class RxEasyHttp {
// 	/**
// 	 * Get请求RxJava形式
// 	 * @param url
// 	 * @return
// 	 */
// 	public static <T> Flowable<T> get(String url, RxEasyConverter<T> converter) {
// 		return get(url, null, converter);
// 	}
// 
// 	public static <T> Flowable<T> get(String url, EasyRequestParams easyRequestParams, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().get(url, easyRequestParams, EasyCacheType.CACHE_TYPE_NO_SETTING, converter);
// 	}
// 
// 	public static <T> Flowable<T> get(String url, int cacheType, RxEasyConverter<T> converter) {
// 		return get(url, null, cacheType, converter);
// 	}
// 
// 	public static <T> Flowable<T> get(String url, EasyRequestParams easyRequestParams, int cacheType, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().get(url, easyRequestParams, cacheType, converter);
// 	}
// 
// 	/**
// 	 * Post请求RxJava形式
// 	 * @param url
// 	 * @return
// 	 */
// 	public static <T> Flowable<T> post(String url, EasyRequestParams easyRequestParams, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().post(url, easyRequestParams, converter);
// 	}
// 
// 	/**
// 	 * post file RxJava形式
// 	 * @param url
// 	 * @param filePath
// 	 * @return
// 	 */
// 	public static <T> Flowable<T> uploadFile(String url, String filePath, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().uploadFile(url, filePath, converter);
// 	}
// }
// 
// Path: easy-http-library-rx/src/main/java/com/yang/easyhttprx/converter/RxEasyStringConverter.java
// public class RxEasyStringConverter implements RxEasyConverter<String> {
//     @Override
//     public String convert(String body) throws Exception {
//         return body;
//     }
// 
//     @Override
//     public void doNothing() {
// 
//     }
// }


import android.app.ProgressDialog;
import android.os.Bundle;
import android.support.annotation.Nullable;
import android.support.v7.app.AppCompatActivity;
import android.text.Editable;
import android.text.TextUtils;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
import com.yang.demo.R;
import com.yang.easyhttprx.RxEasyHttp;
import com.yang.easyhttprx.converter.RxEasyStringConverter;
import org.reactivestreams.Subscription;
import butterknife.BindView;
import butterknife.ButterKnife;
import butterknife.OnClick;
import io.reactivex.FlowableSubscriber;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.annotations.NonNull;
import io.reactivex.functions.Consumer;
package com.yang.demo.activity;





/**
 * Created by yangyang on 2017/2/17.
 */
public class RxGetActivity extends AppCompatActivity {
    @BindView(R.id.url)
    EditText urlView;
    @BindView(R.id.go)
    Button go;
    @BindView(R.id.body)
    TextView body;

    ProgressDialog dialog;
    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.get_main);

        ButterKnife.bind(this);

        dialog = new ProgressDialog(this);
    }

    @OnClick(R.id.go)
    public void go() {
        Editable url = urlView.getText();

        if (TextUtils.isEmpty(url)) {
            Toast.makeText(this, "url is empty", Toast.LENGTH_SHORT);
            return;
        }

// Path: easy-http-library-rx/src/main/java/com/yang/easyhttprx/RxEasyHttp.java
// public class RxEasyHttp {
// 	/**
// 	 * Get请求RxJava形式
// 	 * @param url
// 	 * @return
// 	 */
// 	public static <T> Flowable<T> get(String url, RxEasyConverter<T> converter) {
// 		return get(url, null, converter);
// 	}
// 
// 	public static <T> Flowable<T> get(String url, EasyRequestParams easyRequestParams, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().get(url, easyRequestParams, EasyCacheType.CACHE_TYPE_NO_SETTING, converter);
// 	}
// 
// 	public static <T> Flowable<T> get(String url, int cacheType, RxEasyConverter<T> converter) {
// 		return get(url, null, cacheType, converter);
// 	}
// 
// 	public static <T> Flowable<T> get(String url, EasyRequestParams easyRequestParams, int cacheType, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().get(url, easyRequestParams, cacheType, converter);
// 	}
// 
// 	/**
// 	 * Post请求RxJava形式
// 	 * @param url
// 	 * @return
// 	 */
// 	public static <T> Flowable<T> post(String url, EasyRequestParams easyRequestParams, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().post(url, easyRequestParams, converter);
// 	}
// 
// 	/**
// 	 * post file RxJava形式
// 	 * @param url
// 	 * @param filePath
// 	 * @return
// 	 */
// 	public static <T> Flowable<T> uploadFile(String url, String filePath, RxEasyConverter<T> converter) {
// 		return RxEasyHttpManager.getInstance().uploadFile(url, filePath, converter);
// 	}
// }
// 
// Path: easy-http-library-rx/src/main/java/com/yang/easyhttprx/converter/RxEasyStringConverter.java
// public class RxEasyStringConverter implements RxEasyConverter<String> {
//     @Override
//     public String convert(String body) throws Exception {
//         return body;
//     }
// 
//     @Override
//     public void doNothing() {
// 
//     }
// }


// Path: sample/src/main/java/com/yang/demo/activity/RxGetActivity.java
import android.app.ProgressDialog;
import android.os.Bundle;
import android.support.annotation.Nullable;
import android.support.v7.app.AppCompatActivity;
import android.text.Editable;
import android.text.TextUtils;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
import com.yang.demo.R;
import com.yang.easyhttprx.RxEasyHttp;
import com.yang.easyhttprx.converter.RxEasyStringConverter;
import org.reactivestreams.Subscription;
import butterknife.BindView;
import butterknife.ButterKnife;
import butterknife.OnClick;
import io.reactivex.FlowableSubscriber;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.annotations.NonNull;
import io.reactivex.functions.Consumer;

package com.yang.demo.activity;





/**
 * Created by yangyang on 2017/2/17.
 */
public class RxGetActivity extends AppCompatActivity {
    @BindView(R.id.url)
    EditText urlView;
    @BindView(R.id.go)
    Button go;
    @BindView(R.id.body)
    TextView body;

    ProgressDialog dialog;
    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.get_main);

        ButterKnife.bind(this);

        dialog = new ProgressDialog(this);
    }

    @OnClick(R.id.go)
    public void go() {
        Editable url = urlView.getText();

        if (TextUtils.isEmpty(url)) {
            Toast.makeText(this, "url is empty", Toast.LENGTH_SHORT);
            return;
        }

        RxEasyHttp.get(url.toString(), new RxEasyStringConverter())