observable from infinite stream, using the new apply function