Hay un par de artículos sobre esto, y tengo esto funcionando ... pero quiero saber cómo establecer un número máximo de subprocesos de tareas para mis suscripciones de Observable a la vez.

Tengo lo siguiente para paralelizar el almacenamiento asíncrono de las entradas de registro:

private BlockingCollection<ILogEntry> logEntryQueue;

 logEntryQueue = new BlockingCollection<ILogEntry>();
 logEntryQueue.GetConsumingEnumerable().ToObservable(Scheduler.TaskPool).Subscribe(SaveLogEntry);

Para programar mi guardado ... ¿pero cómo especifico los subprocesos máximos para que el planificador los use de inmediato?