@Test
public void effectPerformerRunsActionWheneverEffectIsRequested() throws Exception {

  PublishSubject<String> upstream = PublishSubject.create();
  TestAction action = new TestAction();
  upstream.compose(Transformers.fromAction(action)).subscribe();
  upstream.onNext("First Time");
  assertThat(action.getRunCount(), is(1));
  upstream.onNext("One more!");
  assertThat(action.getRunCount(), is(2));
}