| public interface Subscriber<T> { | |
| public void onSubscribe(Subscription s); | |
| public void onNext(T t); | |
| public void onError(Throwable t); | |
| public void onComplete(); | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment