Size: a a a

ReactiveX - русскоговорящее сообщество

2020 June 17

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Абстракция observable этого не подразумевает
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Обзервабл это всё, что можно наблюдать. И хот и колд
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Но сабжект принимает в себя всякие штуки даже когда его никто не наблюдает, значит это абстракция хот стрима
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
это все верно)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Корочи вся суть в том что, Сабжект это Observable который принимает ништяки, и затем через onNext выдает их. А в этот момент к нему еще могут приконектиться другие Observers.
Что нельзя сделать в Observable
Верно?
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Singular
Корочи вся суть в том что, Сабжект это Observable который принимает ништяки, и затем через onNext выдает их. А в этот момент к нему еще могут приконектиться другие Observers.
Что нельзя сделать в Observable
Верно?
могут подписаться точно так же, как и на обсервабл
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Aleksey D.
могут подписаться точно так же, как и на обсервабл
Можно пример? чтобы понять где юзать то где то
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Singular
Можно пример? чтобы понять где юзать то где то
сабджект юзать там, где нужно пропихивать что-то извне (на деле очень мало кейсов для использования)
очень часто его можно заменить на самописный обсервабл

например:
- из WS сообщения прокидывать в сабджект
- события кликов на кнопку
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Короче вся полезнкость сабжектов, в том что у него есть onNext метод, и благодаря этому можно последовательно выполнять задачи и передавать их в нужные Observer.
А Observrable все разом делает, когда к нему кто - то подписывается.

Так?
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
нет, совсем не так
источник

S

Singular in ReactiveX - русскоговорящее сообщество
та блин(
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
сабджект - это тот же обсервабл, но в который можно что-то закинуть извне через offer метод (или onNext мб, не помню уже)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Ну я это и написал вроде
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Singular
Ну я это и написал вроде
нет, ты что-то про последовательное написал, а оно одинаково работает
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Aleksey D.
сабджект - это тот же обсервабл, но в который можно что-то закинуть извне через offer метод (или onNext мб, не помню уже)
Я кажется понял. Subject это некий Callback, к которому если кто - то подписан, то при вызове onNext получает эти данные, если нет то данные уходят в никуда. Некий клиент сервер
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Singular
Я кажется понял. Subject это некий Callback, к которому если кто - то подписан, то при вызове onNext получает эти данные, если нет то данные уходят в никуда. Некий клиент сервер
не нужно так усложнять, но если это помогает тебе понять - ок 🤷
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
Aleksey D.
сабджект юзать там, где нужно пропихивать что-то извне (на деле очень мало кейсов для использования)
очень часто его можно заменить на самописный обсервабл

например:
- из WS сообщения прокидывать в сабджект
- события кликов на кнопку
Куча кейсов где есть потоковые данные. или собственные эвенты. Стейтмашины. UI. MVI. Я кучу могу кейсов придумать.)
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Артем Кулик
Куча кейсов где есть потоковые данные. или собственные эвенты. Стейтмашины. UI. MVI. Я кучу могу кейсов придумать.)
и во всех можно обойтись без сабджекта) в части из них я бы вообще пару экзекьюторов предпочел)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
А вот если использую ReplaySubject, то где данные хранятся? Разве это не затратно?
источник

l

lenar in ReactiveX - русскоговорящее сообщество
Singular
Корочи вся суть в том что, Сабжект это Observable который принимает ништяки, и затем через onNext выдает их. А в этот момент к нему еще могут приконектиться другие Observers.
Что нельзя сделать в Observable
Верно?
суть в том что есть спека реактивных стримов. и в них есть просто паблишер, а есть процессор (трансформер в 9ке). и observable = publisher, subject = processor
источник