org.yamcs.client.base

Interface DataObserver<T extends com.google.protobuf.Message>

All Superinterfaces:

Observer<T>

public interface DataObserver<T extends com.google.protobuf.Message>
extends Observer<T>

Method Summary

Modifier and Type	Method and Description
Class<T>	getMessageClass()
default void	unpackNext(com.google.protobuf.Any data)

Methods inherited from interface org.yamcs.api.Observer

complete, complete, completeExceptionally, isCancelled, next, setCancelHandler

Method Detail

getMessageClass

Class<T> getMessageClass()

unpackNext

default void unpackNext(com.google.protobuf.Any data)
                 throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException