java async Subscriber

java async Subscriber

public class NormalSubscriber implements Flow.Subscriber<Long> {    
    private Flow.Subscription subscription;
    private String name = "NormalSubscriber";
    public NormalSubscriber(String name) {
        this.name = name;
    }
    public String getName() {
        return name;
    }
    @Override
    public void onSubscribe(Flow.Subscription subscription) {
        this.subscription = subscription;
        subscription.request(1);
    }
    @Override
    public void onNext(Long item) {
       System.out.printf("odd number: %d", item);            
    }
    @Override
    public void onError(Throwable t) {
        System.out.printf("err:", t.getMessage());
    }
    @Override
    public void onComplete() {
        System.out.printf("odd number check complete");
    }
}