observable.md
84 lines
| 3.0 KiB
| text/x-minidsrc
|
MarkdownLexer
andrei
|
r25 | # Observable | |
| Универсальный способ организации потока сообщений. Данный механизм может | |||
| использоваться для оповещения об изменениях состояний объектов или для доставки | |||
| самостоятельных событий, например, связанных с действиями пользователя. | |||
| Является реализацией классического шаблона наблюдателя с возможность сообщить | |||
| о коце потока событий. Данная реализация не содержит никаких дополнительных | |||
| функций, таких как фильтрация, канал с состоянием, преобразования сообщений и | |||
| т.п. Это сделано специально, чтобы реализация оставалась максимально простой. | |||
| Пример того, как можно создать последовательность из 10 событий: | |||
| ```ts | |||
| var events = new Observable(async (notify, error, complete) => { | |||
| // цикл в котором возникает событие | |||
| for(let i = 0; i < 10; i++) { | |||
| await delay(1000); | |||
| // в качестве данных передается номер события | |||
| notify(i); | |||
| } | |||
| // по окончании последовательности информируем, что событий больше не будет | |||
| compelte(); | |||
| }); | |||
| // создаем окно с отображением хода событий | |||
| var progress = showProgress({ min: 0, max: 9, current: 0}); | |||
| // подписываемся на события | |||
| events.on( | |||
| // обработчик очередного события | |||
| msg => { | |||
| progress.setValue(msg); | |||
| }, | |||
| // обработчик ошибки | |||
| e => { | |||
| progress.showError(e); | |||
| }, | |||
| // обработчик конца потока | |||
| () => { | |||
| progress.close(); | |||
| } | |||
| ); | |||
| ``` | |||
| Пример создания `Observable` из событий другого объекта, например, виджета: | |||
| ```ts | |||
| postCreate() { | |||
| // превращаем события виджета в Observable | |||
| this.mouseMove = new Observable((notify) => { | |||
| this.moveArea.on('mousemove',(x) => notify(x.) ); | |||
| }); | |||
| } | |||
| ``` | |||
| Пример инициализации `Observable` внутри класса и генерация событий: | |||
| ```ts | |||
| class PositionWidget extends Widget { | |||
| _nextPosition: (pos: Position) => void | |||
| _complete: () => void | |||
| readonly position: Observable<Position>; | |||
| constructor(...args[]) { | |||
| super(args); | |||
| this.position = new Observable<Position>((notify, error, complete) => { | |||
| this._nextPosition = notify; | |||
| this._complete = complete | |||
| }); | |||
| } | |||
| destroy() { | |||
| this._complete(); | |||
| super(); | |||
| } | |||
| } | |||
| ``` |