Ist es möglich, `ReplaySubject` zu veranlassen, eine Schließung durchzuführen, wenn man abonniert wird?

Question

Ich möchte eine Cold Observable erstellen, die nur teure Operation starten würde, wenn es ein tatsächliches Abonnement gibt. ReplaySubject würde gut passen, außer für den Teil, der in der Lage sein muss, eine teure Hintergrundoperation zu starten, wenn das eigentliche Abonnement gemacht wird, und nicht auf dem Observablen. Gibt es einen Weg dazu? Eine Art von onSubscribed { ... } Methode.

Answer 1

Hier sind ein paar Optionen:

die teure Operation zu einem doOn(onSubscribe:) Hinzufügen, die zwischen dem Observable und das Abonnement in ist:

let observable = Observable.of(1, 2) 
    .doOn(onSubscribe: { _ in 
     expensiveOperation() 
    }) 

observable 
    .subscribeNext { e in 
     print(e) 
    } 

Herstellung des Observable verbindbar und Trennen des doOn(onSubscribe:):

let observable = Observable.of(1, 2) 
    .publish() 

observable 
    .doOn(onSubscribe: { _ in 
     expensiveOperation() 
    }) 
    .subscribe() 

observable 
    .subscribeNext { e in 
     print(e) 
    } 

observable.connect()