Как вернуть IObservable<T> в aws lambda
Я хочу вернуть 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
Попробуй это:
var values = new [] { 1, 2, 3, };
var observable =
Observable
.Timer(TimeSpan.Zero, TimeSpan.FromSeconds(1.0))
.Zip(values, (_, v) => v);
@JohniMichels - Вам действительно нужно объяснить мне эти два вопроса намного яснее. Я не понимаю, что вы спрашиваете.
Я имею в виду, если я запрошу POST на конечной точке лямбды aws, которая возвращает iobservable, что обеспечит отправку ответа поэлементно? Спрашиваю, потому что даже сериализатор на стороне лямбда, который потребляет весь объект, прежде чем вернуть его строковый эквивалент, заставит клиента ждать 2 секунды и возвращать [1, 2, 3].
@JohniMichels - Да, я не на 100% понимаю, что вы говорите. Наблюдаемый вытолкнет статический список в новый поток, и он будет выдвигать их поэлементно.
Да, когда вы говорите о потоке на той же машине, которая использует сборку, возвращающую iobservable. Я прошу клиента через Интернет, который вызывает лямбда-функцию aws, которая возвращает список в режиме push.
Мне очень жаль, но я действительно не понимаю, о чем вы спрашиваете. Можете ли вы попросить кого-нибудь помочь сформулировать то, что вы просите?
Давайте продолжить обсуждение в чате.
Обеспечивает ли простой ответ iobervable в лямбда-выражении клиентам, потребляющим лямбда-выражение, асинхронный ответ? Как насчет сериализации, не будет ли она потреблять весь ответ перед возвратом?