add test for group leaking messages
use rx TestScheduler to get items emitted instead of waiting for another thread