如何返回IObservable 在aws lambda

Question

我希望在基于推送的通知中返回在响应主体上为AWS lambda函数的使用者流式传输的IEnumerable<T>。

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

因此，这个lambda函数的使用者可以将响应体读取为流，如果我们有lambda响应[1,2,3]并且每个项目之间有一秒等待，则消费者会收到[1，{1秒] } 2，{1秒} 3]。如何做到这一点的任何领导？

Answer 1

试试这个：

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

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