Estoy usando extensiones reactivas para recopilar datos en buffers de 100 ms:

this.subscription = this.dataService
    .Where(x => !string.Equals("FOO", x.Key.Source))
    .Buffer(TimeSpan.FromMilliseconds(100))
    .ObserveOn(this.dispatcherService)
    .Where(x => x.Count != 0)
    .Subscribe(this.OnBufferReceived);

Esto funciona bien. Sin embargo, quiero un comportamiento ligeramente diferente al proporcionado porBuffer operación. Esencialmente, quiero restablecer el temporizador si se recibe otro elemento de datos. Solo cuando no se hayan recibido datos durante los 100 ms completos, quiero manejarlos. Esto abre la posibilidad deNunc manejo de los datos, por lo que también debería poder especificar un recuento máximo. Me imagino algo en la línea de:

.SlidingBuffer(TimeSpan.FromMilliseconds(100), 10000)

He echado un vistazo y no he podido encontrar algo así en Rx. ¿Alguien puede confirmar / negar esto?