It may be that this is a simple matter of running collectContinuously. Now sure if it's that simple though.