В прошлых примерах мы использовали `Subject`'ы и вручную подавали на них значения чтобы создать последовательность. Мы делали так чтобы продемонстрировать некоторые ключевые моменты, а главное, самый основной в Rx метод, `subscribe`. В большинстве случаев `Subject` это не лучший способ создать новый `Observable`. В этом разделе мы рассмотрим более элегантные способы сделать это.

Код [выше](/tests/java/itrx/chapter2/creating/ObservableFactoriesExample.java) ничего не напечатает. Однако заметьте, что это не означает что программа блокируется. По-факту она просто мгновенно завершается.

`defer` не создает новый `Observable`, но позволяет определить каким образом `Observable` будет создан при появлении подписчиков. Подумайте как бы вы создали `Observable` который будет выдавать текущее время. Так как значение только одно, кажется, что здесь нам поможет `just`.

Обратите внимание как второй подписчик, подписавшись на секунду позже, получает такое же время. Это происходит потому что значение времени было вычислено лишь единажды: когда выполнение доходит до метода `just`. Однако в нашем случае мы хотим вычислять текущее время при каждой подписке. `defer` принимает функцию, которая возвращает `Observable` и будет выполнена для каждого нового подписчика.

Все намного проще чем выглядит. Внутри всего лишь функция, которая принимает `Subscriber` для типа `T`. Внутри него мы можем вручную определить события, которые будут выдаваться подписчику.

Еще одним ключевым отличием от использования `Subject` является то, что код выполняется "lazily", только тогда когда прибывает новый подписчик. В примере выше, код выполняется _не_ в момент создания `Observable` (так как подписчиков еще нет), а в момент вызова метода `subscribe`. Это означает, что значения будет вычислены заново для каждого подписчика, как в `ReplaySubject`. Конечный результат похож на `ReplaySubject`, за исключением кеширования. С помощью `create` мы можем легко перенести выполнение в отделный поток, в то время как с `ReplaySubject` нам приходилось бы вручную создавать отдельные потоки для вычисления значений. Мы еще рассмотрим способы сделать выполнение метода `onSubscribe` параллельным.

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

`Future`'ы являются частью Java и вы должно быть сталкивались с ними во время работы с фреймворками, использующими многопоточность. Они являются менее мощным многопоточным инструментом чем Rx, так как возвращают только одно значение. Как правило, вы захотите превратить их в `Observable`.

`Observable` выдает результат `FutureTask` по-готовности, после чего завершается. Если задача была отменена, observable выдаст ошибку. `java.util.concurrent.CancellationException`.

`Observable` это не то же что `Iterable` или `Stream`. `Observable` push-ориентированный, в том смысле, что вызов `onNext` провоцирует стек обработчиков выполниться вплоть до последнего `subscribe` метода (если не задано иначе). Остальные модели pull-ориентированные - значения в них запрашиваются с другой стороны и выполнение блокируется до возвращения результата.