T> s); } public interface Subscriber<T> { public void onSubscribe(Subscription s); public void onNext(T t); public void onError(Throwable t); public void onComplete(); } public interface Subscription { public void request(long n); public void cancel(); } ͯ͢Γͳ͠ʹඇಉظ ޠኮ RxJava ͕ϕʔε