■
package com.example.grpc.serviceapl;package com.example.grpc.serviceapl;/** * Created by rayt on 5/16/16. */
import io.grpc.stub.StreamObserver;import javafx.application.Platform;import javafx.collections.FXCollections;import javafx.collections.ObservableList;
public class StreamObserverImpl implements StreamObserver<ServiceApl.ServiceAplMessageFromServer> {
private ObservableList<String> messages = FXCollections.observableArrayList();
public StreamObserverImpl(ObservableList<String> messages){ this.messages = messages; } void setMessage(ObservableList<String> messages) { this.messages = messages; }
@Override public void onNext(ServiceApl.ServiceAplMessageFromServer value) { Platform.runLater*1;// messagesView.scrollTo(messages.size()); }); }
@Override public void onError(Throwable t) { t.printStackTrace(); System.out.println("Disconnected"); }
@Override public void onCompleted() { System.out.println("Disconnected"); }
}
