Cómo leer el archivo intercalado simultáneamente utilizando extensiones reactivas

Soy nuevo en las extensiones reactivas y me gustaría usarlo (en c #) para leer un archivo que contiene varias transmisiones intercaladas. Básicamente el archivo está en el formato.ABCDABCDABCD.... Preferiría leer el archivo secuencialmente y separar las secuencias (es decir,AAA.., BBB.., etc.) y procesa cada flujo en paralelo, usando hilos separados para cada flujo.

Deberá haber alguna forma de almacenamiento en búfer para asegurarse de que cada flujo pueda permanecer ocupado lo más posible (dentro de los límites, por supuesto). No todos los flujos se inician necesariamente al mismo tiempo, en cuyo caso se deben omitir varios elementos para los flujos retrasados. En este caso, el almacenamiento en búfer puede cerrar la brecha.

Los elementos en el archivo son pequeños (4 bytes) por lo que es bastante hablador. Por lo tanto, también estoy buscando una manera de lidiar con esto de manera eficiente.

Comencé por crear un enumerable para leer el archivo. Esto podría hacerse para suministrar una estructura que contenga el ID de flujo, o los flujos podrían separarse según el orden (número de elemento, número de flujo de los flujos). El último es probablemente más eficiente sin embargo.

Respuestas a la pregunta(2)

Su respuesta a la pregunta