}
});
- private final LoadingCache<Class<?>, ContainerNodeCodecContext<?>> rpcDataByClass = CacheBuilder.newBuilder()
+ private final LoadingCache<Class<?>, ContainerLikeCodecContext<?>> rpcDataByClass = CacheBuilder.newBuilder()
.build(new CacheLoader<>() {
@Override
- public ContainerNodeCodecContext<?> load(final Class<?> key) {
+ public ContainerLikeCodecContext<?> load(final Class<?> key) {
final BiFunction<BindingRuntimeTypes, QName, Optional<? extends ContainerLikeRuntimeType<?, ?>>> lookup;
if (RpcInput.class.isAssignableFrom(key)) {
lookup = BindingRuntimeTypes::findRpcInput;
final ContainerLikeRuntimeType<?, ?> type = lookup.apply(context.getTypes(), potentialQName)
.orElseThrow(() -> new IllegalArgumentException("Cannot find runtime type for " + key));
- return (ContainerNodeCodecContext) DataContainerCodecPrototype.from(key,
+ return (ContainerLikeCodecContext) DataContainerCodecPrototype.from(key,
(ContainerLikeRuntimeType<?, ?>) type, factory).get();
}
}
return getOrRethrow(notificationsByClass, notification);
}
- ContainerNodeCodecContext<?> getRpc(final Class<? extends DataContainer> rpcInputOrOutput) {
+ ContainerLikeCodecContext<?> getRpc(final Class<? extends DataContainer> rpcInputOrOutput) {
return getOrRethrow(rpcDataByClass, rpcInputOrOutput);
}