c# - 将具有不规则长度字节数组的 IObservable 转换为具有常规长度数组的 IObservable

Question

我有一个 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}，等待更多输入)

Answer 1

这很容易。试试这个:

    Bytes
        .SelectMany(b => b)
        .Buffer(10)
        .Select(bs => bs.ToArray());