@Test public void toStringNotNull() { assertThat(sink.toString(), notNullValue()); }
@Override public String toString() { return MoreObjects.toStringHelper(this) .add("numMessageListeners", mMessageListeners.size()) .add("numMessageTypeListeners", mMessageTypeListeners.size()) .add("numPersistentMessageListeners", getNumPersistentListeners()) .add("numMeasurementTypeListeners", mMeasurementTypeListeners.size()) .toString(); }
MessageListenerSink extends AbstractQueuedCallbackSink { @Override public String toString() { return MoreObjects.toStringHelper(this) .add("numMessageListeners", mMessageListeners.size()) .add("numMessageTypeListeners", mMessageTypeListeners.size()) .add("numPersistentMessageListeners", getNumPersistentListeners()) .add("numMeasurementTypeListeners", mMeasurementTypeListeners.size()) .toString(); } }
MessageListenerSink extends AbstractQueuedCallbackSink { @Override public String toString() { return MoreObjects.toStringHelper(this) .add("numMessageListeners", mMessageListeners.size()) .add("numMessageTypeListeners", mMessageTypeListeners.size()) .add("numPersistentMessageListeners", getNumPersistentListeners()) .add("numMeasurementTypeListeners", mMeasurementTypeListeners.size()) .toString(); } MessageListenerSink(); }
MessageListenerSink extends AbstractQueuedCallbackSink { @Override public String toString() { return MoreObjects.toStringHelper(this) .add("numMessageListeners", mMessageListeners.size()) .add("numMessageTypeListeners", mMessageTypeListeners.size()) .add("numPersistentMessageListeners", getNumPersistentListeners()) .add("numMeasurementTypeListeners", mMeasurementTypeListeners.size()) .toString(); } MessageListenerSink(); synchronized void register(KeyMatcher matcher,
            VehicleMessage.Listener listener, boolean persist); synchronized void register(KeyMatcher matcher,
            VehicleMessage.Listener listener); synchronized void register(
            Class<? extends VehicleMessage> messageType,
            VehicleMessage.Listener listener); void register(Class<? extends Measurement> measurementType,
            Measurement.Listener listener); synchronized void unregister(
            Class<? extends Measurement> measurementType,
            Measurement.Listener listener); synchronized void unregister(
            Class<? extends VehicleMessage> messageType,
            VehicleMessage.Listener listener); synchronized void unregister(KeyMatcher matcher,
            VehicleMessage.Listener listener); @Override String toString(); }
MessageListenerSink extends AbstractQueuedCallbackSink { @Override public String toString() { return MoreObjects.toStringHelper(this) .add("numMessageListeners", mMessageListeners.size()) .add("numMessageTypeListeners", mMessageTypeListeners.size()) .add("numPersistentMessageListeners", getNumPersistentListeners()) .add("numMeasurementTypeListeners", mMeasurementTypeListeners.size()) .toString(); } MessageListenerSink(); synchronized void register(KeyMatcher matcher,
            VehicleMessage.Listener listener, boolean persist); synchronized void register(KeyMatcher matcher,
            VehicleMessage.Listener listener); synchronized void register(
            Class<? extends VehicleMessage> messageType,
            VehicleMessage.Listener listener); void register(Class<? extends Measurement> measurementType,
            Measurement.Listener listener); synchronized void unregister(
            Class<? extends Measurement> measurementType,
            Measurement.Listener listener); synchronized void unregister(
            Class<? extends VehicleMessage> messageType,
            VehicleMessage.Listener listener); synchronized void unregister(KeyMatcher matcher,
            VehicleMessage.Listener listener); @Override String toString();  }