System.Reactive Observable из строки объединяет элементы в один элемент как новый Observable - PullRequest
Новая
       19

System.Reactive Observable из строки объединяет элементы в один элемент как новый Observable

0 голосов
/ 06 декабря 2018

У меня есть наблюдаемая, элементы которой испускают строковое значение, которое является только частью всего сообщения, которое я хочу публично предложить в качестве наблюдаемой.

Если элементы появляются следующим образом:

  • "This is "
  • "only part of"
  • " the message."

Я хочу предложить общедоступную наблюдаемую, чьи предметы излучаются как:

  • "This is only part of the message."

И я знаю, когда части сообщения являются полным сообщением к концу периода.

Я пытался получить Buffer оператор для работы, потому что это кажется правильным оператором для моего сценария, но я не знаю, как сказать буферу, что такое условие закрытия или если это вообще возможно.

1 Ответ

0 голосов
/ 07 декабря 2018

Buffer - лучший способ сделать это: 

var source = new Subject<string>();

var result = source.Publish(_source => _source
        .Buffer(_source.Where(s => s.EndsWith(".")))
    )
    .Select(l => l.Aggregate ((x, y) => x + y));

result.Subscribe(s => Console.WriteLine(s));

source.OnNext("This is ");
source.OnNext("only part of");
source.OnNext(" the message.");
source.OnNext("Not. A. Full. Message ");
source.OnNext("but end of stream anyway");
source.OnCompleted();

Buffer принимает параметр, который указывает, где должно произойти разделение групп, которое мы указываем с помощью предложения where.Buffer объединяет сообщения в список, который мы затем агрегируем с помощью Агрегата Linq.

EDIT :

Publish позволяет избежать повторной подписки.Если вы удалите Publish, решение будет выглядеть следующим образом и будет работать: 

var result2 = source.Buffer(
        source.Where(s => s.EndsWith("."))
    )
    .Select(l => l.Aggregate((x, y) => x + y));

Однако, result2 будет подписан дважды на source, что может быть источником ошибокособенно если source не очень хорошо реализован или ведет себя как наблюдаемый.Поэтому, когда вы дважды подписываетесь на наблюдаемое, лучше всего использовать Publish, который, по сути, «перенаправляет» сообщения из одной подписки в несколько подписок.

...