Исходное сообщение
"Выпуск серверной JavaScript-платформы Node.js 0.10" Отправлено Andrey, 12-Мрт-13 20:37
> что будет, если приедет невалидное из сокета или клиент просто отвалится? > вообщем, где обработка ошибок? Обработка ошибок - это как раз одна из сильных сторон Reactive Extensions. В моем примере ошибка будет пробрасываться по цепочке и в результате клиент получит ответ { status: "error", details: .... } Например, можно создать функтор (failover), который перехватывает ошибки и повторяет попытку через время, и так, например, три раза, если ошибка не прекращается - увеличивает таймаут и т.д. Теперь этот функтор можно комбинировать с любой асинхронной операцией: file.readAll().failover(times(3), sec(15)) socket.read().failover(times(10), sec(15)) topic.readMessages().failover(times(3), sec(3)) Дальше этот алгоритм можно покрыть тестами и прогнать их за одну милисекунду используя концепцию "виртуального времени" :). RX устроен таким образом, что вы не используете никаких Sleep-ов явно, а отправляете задачу в scheduler (ThreadPool, EventLoop, NewThread, Immediate ....) и указываете когда ее выполнить, поэтому в тестах как правило используется TestScheduler на котором время "течет" быстрее. Библиотека спроектирована очень грамотно. Рекомендую ознакомительное видео http://channel9.msdn.com/Blogs/Charles/Erik-Meijer-Rx-in-15-... Всякие futures, async, promises - это частный случай RX. Еще очень легко управлять временем жизни ресурсов. Что делать, например, если возникла ошибка внутри сложного алгоритма или клиент нажал кнопку отмена и надо отписаться от событий, освободить ресурсы, но это уже тема для отдельного разговора ...

Ваше сообщение
Имя*:
EMail:	Для отправки ответов на email укажите знак ! перед адресом, например, !user@host.ru (!! - не показывать email). Более тонкая настройка отправки ответов производится в профиле зарегистрированного участника форума.
Заголовок*:
Сообщение*:	>> что будет, если приедет невалидное из сокета или клиент просто отвалится? >> вообщем, где обработка ошибок? > Обработка ошибок - это как раз одна из сильных сторон Reactive Extensions. > В моем примере ошибка будет пробрасываться по цепочке и в результате > клиент получит ответ { status: "error", details: .... } > Например, можно создать функтор (failover), который перехватывает ошибки и повторяет попытку > через время, и так, например, три раза, если ошибка не прекращается > - увеличивает таймаут и т.д. Теперь этот функтор можно комбинировать с > любой асинхронной операцией: > file.readAll().failover(times(3), sec(15)) > socket.read().failover(times(10), sec(15)) > topic.readMessages().failover(times(3), sec(3)) > Дальше этот алгоритм можно покрыть тестами и прогнать их за одну милисекунду > используя концепцию "виртуального времени" :). RX устроен таким образом, что вы > не используете никаких Sleep-ов явно, а отправляете задачу в scheduler (ThreadPool, > EventLoop, NewThread, Immediate ....) и указываете когда ее выполнить, поэтому в > тестах как правило используется TestScheduler на котором время "течет" быстрее. > Библиотека спроектирована очень грамотно. Рекомендую ознакомительное видео http://channel9.msdn.com/Blogs/Charles/Erik-Meijer-Rx-in-15-Minutes > Всякие futures, async, promises - это частный случай RX. > Еще очень легко управлять временем жизни ресурсов. Что делать, например, если возникла > ошибка внутри сложного алгоритма или клиент нажал кнопку отмена и надо > отписаться от событий, освободить ресурсы, но это уже тема для отдельного > разговора ...
	Введите код, изображенный на картинке: