PubSubReader should detect idle topic and propagate it to watermark estimator

[tisonet]

PubSubReader doesn't fulfil the complete contract of Watermark estimator. The idle() method is not called when topic doesn't have more data.

Reader has to detect idle topic and propagates this signal to watermark estimator.