Class EntryFunctionEncoder<K,V,O>

java.lang.Object
org.infinispan.cache.impl.EntryFunctionEncoder<K,V,O>
All Implemented Interfaces:
Function<org.reactivestreams.Publisher<CacheEntry<K,V>>, O>, org.infinispan.commands.functional.functions.InjectableComponent

@ProtoTypeId(1326) public class EntryFunctionEncoder<K,V,O> extends Object implements Function<org.reactivestreams.Publisher<CacheEntry<K,V>>, O>, org.infinispan.commands.functional.functions.InjectableComponent
  • Method Details

    • apply

      public O apply(org.reactivestreams.Publisher<CacheEntry<K,V>> iPublisher)
      Specified by:
      apply in interface Function<K,V>
    • inject

      public void inject(ComponentRegistry registry)
      Specified by:
      inject in interface org.infinispan.commands.functional.functions.InjectableComponent