Есть объект генерирующий события (EventEmitter)
obj.on('data', f(data))
В событие поступают допустим числа 1..10, т.е.
f(1), f(2), ...f(10)
Можно ли как то такой EventEmitter переделать на генератор, чтобы писать код типа
let dataGenerator = createGenerator(obj);
for (let i of dataGenerator) { console.log(i) }

Для одиночных событий, такое легко переделывается на промисы
obj.on('end', f(data))

function onEnd(obj){
    return new Promise((resolve) => {
            obj.on('end', (data) => resolve(data))
        });
}
и теперь можно писать
data = await onEnd(obj);

Используй subject
https://ru.stackoverflow.com/questions/624489/angular-2-eventemitter-%d1%81%d0%be%d0%b1%d1%8b%d1%82%d0%b8%d0%b5-%d0%b2%d1%8b%d0%b7%d1%8b%d0%b2%d0%b0%d0%b5%d1%82%d1%81%d1%8f-%d0%bd%d0%be-%d0%b4%d0%b0%d0%bd%d0%bd%d1%8b%d0%b5-%d0%bd%d0%b5-%d0%be%d0%b1%d0%bd%d0%be%d0%b2%d0%bb%d1%8f%d1%8e%d1%82%d1%81%d1%8f/624631#624631

О вообще смотри на библиотеку RxJs
Там как раз работа с событиями  как с потоком событий с применением аналога Linq

(3) А можешь пример кода написать, а то я как то не дохожу сам

(0) Я не понял, что генератор должен вернуть

(5) Должен возвращать, то что приходит в событие on('data')

(6) Ну, ты можешь так же елдить промис. Только что потом с этой пачкой промисов делать?

Классический пример (хотя и не мой) - это асинхронное построчное чтение файла
fs = reqire('fs');
f = fs.readFile('C:/tmp/text.txt');
f.on('data', (data) => {})

(8) Хочется как обычно в цикле обходить

Просто из контекста неясно, зачем так заморачиваться

(13) Ради красоты кода. Так то задача уже решена на колбэках

(15) Не будем это обсуждать в данной ветке

Есть вот такая хрень https://github.com/tj/co
Но сам не пробовал, врать не буду.

(17) Я это читал, но как это применить так и не осилил

Да хз. Ну типа

const createGenerator = obj => {
  return function* () {
    yield new Promise(resolve => {
      obj.on('end', data => resolve(data))
    }
  }
}

https://habrahabr.ru/company/jugru/blog/302284/

(19) А как тогда воспользоваться такой штукой?

(21) типа так:

let gen = createGenerator(obj)
for (let p of gen()) {
// p - это Promise
  p.then(d => console.log(d))
}

(22) в данном случае
d - EventEmitter

(23) ну, это уже зависит от твоего obj.

(23) Вру, приходи сообщение, но только 1 раз

Да действительно и должен приходить эвент эмиттер, но явно больше чем 1 раз

Вот такой вот код получился. Красивее уже не делается
https://gist.github.com/a-sitnikov/3f222788490ff5a54d1057258262476c

Вот это

    await imapConnect(imap);
    await openInbox('INBOX/заявки');

я так понимаю, будет синхронно выполняться?

И еще я пока не понимаю, что в синтаксисе async/await будет в resolve

(28) а как же еще.
Нельзя же открыть папку не подключившись вначале

(29) неопределено конечно же

(28) не синхронно, а последовательно.
Можно запустить две задачи и подождать асинхронно завершения 2 х задач.
https://habrahabr.ru/post/282477/

let [firs,second] = await Promise.all([imapConnect(imap), openInbox('INBOX/заявки')]);

(29) resolve это безошибочное завершение задачи.
В противном случае будет выкинута ошибка которую нужно ловить.

Смотри https://habrahabr.ru/post/282477/

(32) Так это не параллельные задачи. 2 зависит от 1

(34) Асинхронность и параллельность не одно и тоже.
Задачи выполняются последовательно, но асинхронно.
Асинхронность заключается в тос, что при вызове await, поток возвращается в пул где может выполнять другие задачи из очереди. При окончании задачи резултьтат ставится в очередь и задача начинает выполнятся с места await.
Внутри конечный автомат . Поэтому ты можешь использовать await в циклах, рекурсиях итд

Ладно пусть не параллельно.
Нов чем преимущество такого написания кода?

(33) Я знаю, как работает промис. Я спросил, по-сути, где в случае await писать то, что было в then()

(37) Все что дальше идет - это как бы виртуальный then

(32) Кстати, в этом случае так делать нельзя. Promise.all() не регламентирует порядок выполнения промисов. А у него четко: сначала соединяемся, потом открываем папку.

(38) Да, я почитал уже, что await возвращает значение из вызова resolve.

Если нужно внутри цикла писать, то незаменимая вещь.
Например прервать цикл по асинхронному условию

асинхронное условие и прерывание цикла это блин

действительно чем то напоминает "Копайте пока здесь!!! А я схожу и узнаю где нужно!"

(42) Ну а как еще? Сначала разрешить для всех элементов цикла, а потом проверять7

(40) Я привел пример когда последовательность не важна, а нужно выполнить параллельно.

(36) Еще раз при выполнение задач например запрос к базе данных, HTTP запросе это долгие операции которые будут блокировать поток.

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

Для клиента не столь важно, но тоже не стоит блокировать рабочий поток и поддерживать единообразие. Например в .Net Core для асинхронных методов не синхронных аналогов.
Нужно дополнительно использовать примитивы сихпронизации

Например найти первую строчку в файле содержащую текст.
Причем строчки приходят асинхронно

(42) "Блин" — это когда у тебя любой поход в БД, например, асинхронный. А жить как-то надо.

(46) "асинхронно" приходят те которые ищем или "строчки текста" среди которых ищем?

(47) Можно через Promise.all запустить две задачи.
Одна задача на завершение по таймеру, а вторя долгая операция.
Если первая задача завершилась раньше, то вторую задачу можно и не ждать

https://ru.stackoverflow.com/questions/583438/%d0%a2%d0%be%d1%87%d0%bd%d0%be%d0%b5-%d0%bf%d0%be%d0%b2%d1%82%d0%be%d1%80%d0%bd%d0%be%d0%b5-%d0%b2%d1%8b%d0%bf%d0%be%d0%bb%d0%bd%d0%b5%d0%bd%d0%b8%d0%b5-%d1%86%d0%b8%d0%ba%d0%bb%d0%b0-%d1%87%d0%b5%d1%80%d0%b5%d0%b7-%d0%be%d0%bf%d1%80%d0%b5%d0%b4%d0%b5%d0%bb%d0%b5%d0%bd%d0%bd%d1%8b%d0%b5-%d0%bf%d1%80%d0%be%d0%bc%d0%b5%d0%b6%d1%83%d1%82%d0%be%d0%ba-%d0%b2%d1%80%d0%b5%d0%bc%d0%b5%d0%bd%d0%b8-%d0%bf%d0%be%d1%81%d0%bb%d0%b5-%d0%b5%d0%b3/583827#583827

(49) Ты путаешь Promise.all и Promise.race

(50) Да прошу прощения. В .Net Task.WhenAny
Сейчас на TS не пишу. Забываю