Конвертировать IObservableс байтовыми массивами неправильной длины в IObservableс массивами регулярной длины - PullRequest
Новая
       14

Конвертировать IObservableс байтовыми массивами неправильной длины в IObservableс массивами регулярной длины

1 голос
/ 07 октября 2011

У меня есть IObservable<byte[]>, который дает мне неопределенное количество байтов в массиве байтов.Я хочу знать, как я иду от этого к возвращению IObservable<byte[]> с установленным количеством байтов в каждом байтовом массиве.Давайте предположим, что мы хотим 10 байтов за раз.

То есть, если я получу следующий ввод, если я буду подписываться: 

{1, 2, 3, 4}
{5, 6}
{7, 8, 9}
{10}
{11, 12, 13, 14, 15}
{16}
{17, 18}
{19, 20}

Bytes.Subscribe(b => Console.WriteLine(b.Length));

Вывод будет 

3
2
3
1
5
1
2
2

Я хотел бы преобразовать приведенный выше ввод в следующее: 

{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
{11, 12, 13, 14, 15, 16, 17, 18, 19, 20}

Bytes.<WhateverItTakesToDoThat>.Subscribe(b => Console.WriteLine(b.Length));

Вывод будет 

10
10

Он также должен работать, если поступает количество байтовв котором больше, чем один выходной пакет, то есть: 

{21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32}
{33, 34, 35, 36, 37, 38, 39, 40, 41}
{42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52}

Должен быть превращен в 

{21, 22, 23, 24, 25, 26, 27, 28, 29, 30}
{31, 32, 33, 34, 35, 36, 37, 38, 39, 40}
{41, 42, 43, 44, 45, 46, 47, 48, 49, 50}

(и удерживать {51, 52}, ожидая большего вводаприйти)

Ответы [ 2 ]

4 голосов
/ 08 октября 2011

Это легко.Попробуйте это: 

    Bytes
        .SelectMany(b => b)
        .Buffer(10)
        .Select(bs => bs.ToArray());
1 голос
/ 07 октября 2011

Я придумал одно решение, немного подумав и повозившись.Следующий код делает то, что я хочу: 

Bytes.Select( b => b.ToObservable() ) // Convert input to IObservable<IObservable<byte>>
.Merge( 1 ) // Merges the IObservable<IObservable<byte>> to an IObservable<byte>
            // with the bytes in the right order
.Buffer( 4 ) // Wait until we have 4 bytes ready
.Select( bl => bl.ToArray() ) // Take these 4 bytes and turn them back into an array
.Subscribe( b => Console.WriteLine( b.Length ) );

Это, вероятно, неэффективно, и я почти уверен, что это не самый эффективный способ сделать это, так что если кто-то может придумать лучше,более эффективное решение, я на уши!

...