TestSubject event scheduling works differently than specified in its javadoc

[akarnokd]

The javadoc indicates that using the onNext(T value, long timeInMilliseconds) and the other methods will schedule an event emission to the specified absolute time, but the code schedules the emission relative to the underlying scheduler's now() value. This only works as expected when using with the TestScheduler at time 0. I don't see any uses of this class and suggest removing it completely to avoid confusion.

[zsxwing]

+1 for removing TestSubject

[benjchristensen]

I have used it in the Turbine project with success.

Help me confirm the confusion, is it because it has both onNext(T) and onNext(T, timeInMilliseconds)?

If that's why then yes I can see why it's confusing. It works, but only if you know how to use it.

Here is an examples of me using it: https://github.com/Netflix/Turbine/blob/22246ce26d812813e2a242d2f42cfc432a45a8b2/turbine-core/src/test/java/com/netflix/turbine/aggregator/StreamAggregatorTest.java#L604

[benjchristensen]

@headinthebox Do you have an opinion on keeping or removing this? I'm okay removing it due to its confusion.

[benjchristensen]

Added docs in #1796 while reviewing with @headinthebox