/* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools | Templates * and open the template in the editor. */ package subscriber; import java.util.concurrent.Flow.Subscriber; import java.util.concurrent.Flow.Subscription; /** * * @author le */ public class WertAdapter implements Subscriber { private SubscriberView view; private Datenmodell3 model; private Subscription subscription; public WertAdapter(SubscriberView view, Datenmodell3 model) { this.view = view; this.model = model; } public void einschreiben() { model.addWertSubscription(this); } @Override public void onSubscribe(Subscription subscription) { this.subscription = subscription; subscription.request(1); } @Override public void onNext(Integer item) { view.getLblZahl().setText(String.valueOf(item)); subscription.request(1); } @Override public void onError(Throwable throwable) { } @Override public void onComplete() { } }