Ҳолати маълумотҳои Subject дар RxJava кадом навъи ҷараёнро ифода мекунад ва чӣ гуна аз дигар навъҳо фарқ мекунад?

Subject дар RxJava — это махсуси навъи ҷараёни маълумот аст, ки ҳамон вақт Observable ва Observer мебошад. Ин маъно дорад, ки он метавонад маълумотро ҳамон вақт ба (обунакунандагон) интизор шавад ва ҳам қабул кунад (аз дигар Observable-ҳо).

Фарқиятҳо байни Subject ва Observable оддӣ:

• Мултитаскинг: Subject имкон медиҳад, ки чандин обунакунанда маълумоти якхела гиранд, баръакс аз Observable-ҳои оддӣ, ки ба таври пешфарз unicast мебошанд.
• Имконият барои фиристодани рӯйдодҳо дастӣ: Шумо метавонед ба таври барномавӣ методҳои onNext(), onError(), onComplete()-ро дар Subject даъват кунед, то ҷараёни маълумотро назорат кунед.
• Намудҳои гуногуни Subject: Мувофиқи мавҷудияти PublishSubject, BehaviorSubject, ReplaySubject ва AsyncSubject, ҳар яке хусусиятҳои хоси худро дар нигоҳдорӣ ва интизорӣ доранд.

Масалан барои истифодаи PublishSubject:

PublishSubject<String> subject = PublishSubject.create();

subject.subscribe(item -> System.out.println("Обуна 1: " + item));

subject.onNext("Салом");
subject.onNext("ҷаҳон");

subject.subscribe(item -> System.out.println("Обуна 2: " + item));

subject.onNext("!");

Дар ин ҷо, обунаи дуввум танҳо рӯйдод "!"-ро мегирад, зеро PublishSubject гузаштаҳои арзишҳоро нигоҳ намедорад.