Package com.github.jy2

Interface Subscriber<T>

public interface Subscriber<T>

  • Method Summary

    Modifier and Type Method Description
    default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer)  
    default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength)  
    default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength, int timeout)  
    default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength, int timeout, int maxExecutionTime)  
    java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength, int timeout, int maxExecutionTime, java.lang.reflect.Method method)  
    java.lang.String getRemoteJavaType()
    WARNING: this will only work after message listener was added
    java.lang.String getRemoteRosType()
    WARNING: this will only work after message listener was added
    boolean isLatched()
    WARNING: this will only work after message listener was added
    void removeAllMessageListeners()  
    void removeMessageListener​(java.lang.Object handle)  

  • Method Details

    • addMessageListener

      default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer)

    • addMessageListener

      default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength)

    • addMessageListener

      default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength, int timeout)

    • addMessageListener

      default java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength, int timeout, int maxExecutionTime)

    • addMessageListener

      java.lang.Object addMessageListener​(java.util.function.Consumer<T> consumer, int queueLength, int timeout, int maxExecutionTime, java.lang.reflect.Method method)

    • removeMessageListener

      void removeMessageListener​(java.lang.Object handle)

    • removeAllMessageListeners

      void removeAllMessageListeners()

    • isLatched

      boolean isLatched()
      WARNING: this will only work after message listener was added

    • getRemoteJavaType

      java.lang.String getRemoteJavaType()
      WARNING: this will only work after message listener was added

    • getRemoteRosType

      java.lang.String getRemoteRosType()
      WARNING: this will only work after message listener was added