Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val subject = BehaviorSubject.create(Unit)

	subject
			.subscribeOn(Schedulers.computation())
			.subscribe {

Diolor

// build.gradle
apply plugin: EmailPlugin


// build src file
open class EmailPlugin : Plugin<Project> {
	override fun apply(project: Project) {
      // DO stuff
  	}
}

Diolor

class MyActivity extends Activity implements StateView<FilterButtonState> {

  private Button button;
  @Inject
  FilterButtonPresenter presenter;

  @Override
	protected void onCreate(Bundle savedInstanceState) {
    // set some content views
    Component.activity(this).inject(this); // dagger 2 injection

Diolor

@RunWith(MockitoJUnitRunner.class)
class FilterButtonPresenterTest {

  @Mock
  AccountInteractor accountInteractor;
  @Mock
  StateView<FilterButtonState> view;
  @InjectMocks
  FilterButtonPresenter testee;

Diolor

@ViewScope // dagger 2 scope
class FilterButtonPresenter implements Presenter<FilterButtonState, StateView<FilterButtonState>> {

  final AccountInteractor accountInteractor;
  Subscription subscription;

  @Inject // dagger 2 dependency injection
  FilterButtonPresenter(AccountInteractor accountInteractor){
    this.accountInteractor = accountInteractor;
  }

Diolor

public interface Presenter<S, V extends StateView<S>> {

  void onStart(V view);

  void onStop();
}

Diolor

public class MainActivity extends AppCompatActivity {

    private final Disposable disposable = Observable.timer(5, TimeUnit.SECONDS)
            .subscribe(o ->
                    new MyDialogFragment()
                            .show(getSupportFragmentManager(), "DIALOG_TAG")
            );

    @Override
    protected void onPause() {

Diolor

public class MainActivity extends AppCompatActivity {

    private final PublishSubject<Object> dialogDisplaySubject = PublishSubject.create();
    private final Disposable disposable = dialogDisplaySubject
            .subscribe(o ->
                    new MyDialogFragment()
                            .show(getSupportFragmentManager(), "DIALOG_TAG")
            );

    @Override

Diolor

private final PublishSubject<Void> viewClickedSubject = PublishSubject.create();
private final CompositeSubscription startStopCompositeSubscription = new CompositeSubscription();

@Override
protected void onStart() {
	super.onStart();
	
	view.setOnClickListener(v-> viewClickedSubject.onNext(null));

	Subscription subscription = viewClickedSubject

Diolor

PublishSubject<Void> viewClickedSubject = PublishSubject.create();
CompositeSubscription startStopCompositeSubscription = new CompositeSubscription();

protected void onStart() {

   view.setOnClickListener(v-> viewClickedSubject.onNext(null));
   
   Subscription subscription = viewClickedSubject
       .flatMap(aVoid-> api.getAlert())
       .subscribe(this::makeAlertToast, Throwable::printStackTrace);