Marchuck

package evalu.com.evalu.utils.rx;

import android.content.Context;
import android.os.Build;
import android.support.annotation.RequiresApi;
import android.util.AttributeSet;
import android.view.MotionEvent;
import android.widget.ScrollView;

import io.reactivex.subjects.PublishSubject;

Marchuck

CatPresenter{
  
  BehaviorSubject<List<Cat>> catsSubject = BehaviorSubject.create();
  Disposable catsDisposable;
  
 void onCreate(){
   
   someClient.subscribe( cats -> {  catsSubject.onNext(cats)  })

Marchuck

package xD;

import android.content.Context;
import android.content.res.AssetFileDescriptor;
import android.media.MediaPlayer;
import android.util.Log;

import hugo.weaving.DebugLog;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;

Marchuck

import android.bluetooth.BluetoothGatt;
import android.bluetooth.BluetoothGattCharacteristic;
import android.bluetooth.BluetoothGattDescriptor;
import android.support.annotation.NonNull;
import android.util.Log;
import java.util.UUID;
/**
* Helper which enables or disables BLE gatt updates from connected peripheral, not tested in production
*/

Marchuck

package com.emil.android.util;

import android.content.Context;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.telephony.TelephonyManager;

/**
 * Check device's network connectivity and speed 
 * @author emil http://stackoverflow.com/users/220710/emil

Marchuck

/**
 * @author Lukasz Marczak
 * @since 28.09.16.
 */
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;
import android.view.View;

Marchuck

int threadCt = Runtime.getRuntime().availableProcessors() + 1;

ExecutorService executor = Executors.newFixedThreadPool(threadCt);

Schedulers scheduler = Schedulers.from(executor);

Observable.range(1,1000)
    .groupBy(i -> batch.getAndIncrement() % threadCt )
    .flatMap(g -> g.observeOn(scheduler)
        .map(i -> intenseCalculation(i))

Marchuck

public static void main(String[] argv) {
        new CesarCipher().solve();
    }

    public void solve() {
        Scanner in = new Scanner(System.in);
        int t = Integer.valueOf(in.nextLine());
        String line = in.nextLine();
        StringBuilder sb = new StringBuilder();
        String keys = in.nextLine();

Marchuck

String[] getIds = new String[]{"id:0", "id:1", "id:2", "id:3"};
        rx.Observable.just(getIds)
                .flatMap(new Func1<String[], Observable<String>>() {
                    @Override
                    public Observable<String> call(String[] strings) {
                        //dla kazdego id odpytaj api
                        return Observable.from(strings);
                    }
                }).flatMap(new Func1<String, Observable<Integer>>() {
            @Override

Marchuck

rx.Observable.range(1, 100).map(i -> String.valueOf(i).concat(
                (i % 15 == 0 ? "FizzBuzz" : i % 3 == 0 ? "Fizz" : i % 5 == 0 ? "Buzz" : "")))
                .subscribe(System.out::println);


OR, more readable:
  
 rx.Observable.range(1, 100).map(i -> i + suffixFor(i)).subscribe(System.out::println);

...