TestSub.java

public class TestSub<T> 
  implements Observable.OnSubscribe<T> {
  Subscriber<T> sub;
  public void call(Subscriber<T> sub) {
    this.sub = sub;
  }
  public void onNext(T data) {
    sub.onNext(data);
  }
  ...
}