Package com.tangosol.net.topic

Class Subscriber.Convert<V,U>

java.lang.Object
com.tangosol.net.topic.Subscriber.Convert<V,U>
Type Parameters:
V - the type of the topic value
U - the type of the value returned to the subscriber
All Implemented Interfaces:
ExternalizableLite, PortableObject, Subscriber.Option<V,U>, Serializable
Enclosing interface:
Subscriber<V>
public static class Subscriber.Convert<V,U> extends Object implements Subscriber.Option<V,U>, ExternalizableLite, PortableObject
The Convert option specifies a ValueExtractor that will convert topic values that a subscriber is interested in receiving prior to sending them to the subscriber. Note that all members of a subscriber group share a single converter. If members join the group using different converter then the last one to join will set the converter function for the group.
See Also:

  • Constructor Details

    • Convert

      public Convert()
      Default constructor for serialization.

    • Convert

      protected Convert(ValueExtractor<? super V,U> extractor)

  • Method Details

    • getExtractor

      public ValueExtractor<? super V,U> getExtractor()
      Return the option's converter function.
      Returns:
      the converter function

    • using

      public static <V, U> Subscriber.Convert<V,U> using(ValueExtractor<? super V,U> extractor)
      Return a Convert option with the specified extractor.
      Parameters:
      extractor - the converter extractor
      Returns:
      the Filtered option

    • readExternal

      public void readExternal(DataInput in) throws IOException
      Description copied from interface: ExternalizableLite
      Restore the contents of this object by loading the object's state from the passed DataInput object.
      Specified by:
      readExternal in interface ExternalizableLite
      Parameters:
      in - the DataInput stream to read data from in order to restore the state of this object
      Throws:
      IOException - if an I/O exception occurs

    • writeExternal

      public void writeExternal(DataOutput out) throws IOException
      Description copied from interface: ExternalizableLite
      Save the contents of this object by storing the object's state into the passed DataOutput object.
      Specified by:
      writeExternal in interface ExternalizableLite
      Parameters:
      out - the DataOutput stream to write the state of this object to
      Throws:
      IOException - if an I/O exception occurs

    • readExternal

      public void readExternal(PofReader in) throws IOException
      Description copied from interface: PortableObject
      Restore the contents of a user type instance by reading its state using the specified PofReader object.
      Specified by:
      readExternal in interface PortableObject
      Parameters:
      in - the PofReader from which to read the object's state
      Throws:
      IOException - if an I/O error occurs

    • writeExternal

      public void writeExternal(PofWriter out) throws IOException
      Description copied from interface: PortableObject
      Save the contents of a POF user type instance by writing its state using the specified PofWriter object.
      Specified by:
      writeExternal in interface PortableObject
      Parameters:
      out - the PofWriter to which to write the object's state
      Throws:
      IOException - if an I/O error occurs