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