diff options
| author | grigoriypisar <[email protected]> | 2026-05-15 12:39:16 +0300 |
|---|---|---|
| committer | grigoriypisar <[email protected]> | 2026-05-15 13:17:12 +0300 |
| commit | 70816c23b5ea624862890f76af03a3235864c528 (patch) | |
| tree | 59a5ba6b11a78c11f0be6ba3c7832502a3ad2ada /library/cpp/threading/equeue | |
| parent | f772af7d9a1499ea8d87d047fbf0d75b891776ac (diff) | |
added new streaming contraint
## Что означает Streaming Constraint
Пусть `O` - колабл для которого выставлен Streaming Constraint и `I` - множество входов оператора для которых также выставлен Streaming Constraint.
### Streaming constraint для Unordered List
Если `O` принимает на вход List и логически является Unordered (нету гарантий на порядок выхода относительно проядка входа), то:
* При добавлении одного элемента в конец списка любого входа из `I` -- в мульти множестве результата `O` могут только появиться новые значения (либо ничего не добавится)
### Streaming constraint для Ordered List
Тоже самое, что и для Unordered List, но добавляется ограничение, что:
* При добавлении одного элемента в конец списка любого входа из `I` -- в упорядоченный список строк, являющийся результатом `O` могут добавиться строки только в конец списка
### Streaming constraint для Stream / Flow
Тоже самое, что для Ordered / Unordered List, но добавляется ограничение:
* Если в любом из входов `I` типа Stream / Flow возможны Yield, то обновлённый результат оператора должен выводиться с ограниченной задержкой при поступлении Yield
commit_hash:1e9e2deac133179c46ad15daa32fb421a3998296
Diffstat (limited to 'library/cpp/threading/equeue')
0 files changed, 0 insertions, 0 deletions