Как вернуть IObservable <T>в aws лямбду - PullRequest
0 голосов
/ 15 марта 2019

Я хочу вернуть IEnumerable<T>, который передается в теле ответа для потребителя лямбда-функции AWS в push-уведомлении.

Consumer|---Call---------Object1------Object2----Object3----Finish
              v           ^            ^         ^          ^
Lambda  |---Start-----Object1-----Object2------Object3-----End

Так что потребитель этой лямбдыФункция может прочитать тело ответа в виде потока, в анекдоте, если бы у нас лямбда-ответ отвечал [1,2,3] с секундным ожиданием между каждым элементом, то потребитель получал бы [1, {1 секунда} 2, {1 секунда}3].Любое руководство о том, как это сделать?

1 Ответ

0 голосов
/ 15 марта 2019

Попробуйте это:

var values = new [] { 1, 2, 3, };

var observable =
    Observable
        .Timer(TimeSpan.Zero, TimeSpan.FromSeconds(1.0))
        .Zip(values, (_, v) => v);
...