javax.ws.rs.sse.InboundSseEvent#readData ( )源码实例Demo

@Override
public void onNext(InboundSseEvent t) {
    LOG.entering(SseTypeSafeProcessor.class.getName(), "onNext", t);
    if (incomingSubscription == null) {
        throw new IllegalStateException("not subscribed");
    }
    if (!isClosed.get()) {
        @SuppressWarnings("unchecked")
        T data = (T) t.readData(type);
        for (Subscriber<? super T> subscriber : subscribers) {
            subscriber.onNext(data);
        }
    }
    LOG.exiting(SseTypeSafeProcessor.class.getName(), "onNext");
}
 

public RestSBServerSentEvent(Type type, DeviceId deviceId, InboundSseEvent sseEvent) {
    super(type, deviceId);
    checkNotNull(sseEvent);
    data = sseEvent.readData();
    id = sseEvent.getId();
    name = sseEvent.getName();
    comment = sseEvent.getComment();
}
 

private static void print(InboundSseEvent event) {
    final Stats stats = event.readData(Stats.class, MediaType.APPLICATION_JSON_TYPE);
    System.out.println(stats.getTimestamp() + ": " + stats.getLoad() + "%");
}
 

private static void receiveEvent(InboundSseEvent event) {
    sseHeaderValue = event.readData();
}