Saya perlu membuat langganan ke Observableyang segera dibuang saat pertama kali dipanggil.

Apakah ada sesuatu seperti:

observable.subscribeOnce(func);

Kasing penggunaan saya, saya membuat langganan dalam pengendali rute ekspres dan langganan dipanggil beberapa kali per permintaan.

Tidak 100% yakin tentang apa yang Anda butuhkan, tetapi jika Anda hanya ingin mengamati nilai pertama, gunakan salah satu first()atau take(1):

observable.first().subscribe(func);

catatan: .take(1)dan .first()keduanya berhenti berlangganan secara otomatis ketika kondisinya terpenuhi

Pembaruan dari RxJS 5.5+

Dari komentar oleh Coderer .

import { first } from 'rxjs/operators'

observable
  .pipe(first())
  .subscribe(func);

Inilah sebabnya

RxJS memiliki beberapa dokumentasi terbaik yang pernah saya temui. Mengikuti tautan di bawah ini akan membawa Anda ke tabel penggunaan pemetaan yang sangat membantu bagi operator. Misalnya, di bawah "Saya ingin mengambil nilai pertama" kasus penggunaan tiga operator: first, firstOrDefault, dan sample.

Catatan, jika urutan yang dapat diamati selesai tanpa pemberitahuan, maka firstoperator akan memberi tahu pelanggan tentang kesalahan sementara firstOrDefaultoperator memberikan nilai default kepada pelanggan.

pencarian kasus penggunaan operator

Jika Anda ingin memanggil Observable hanya satu kali, itu berarti Anda tidak akan menunggu streaming darinya. Jadi menggunakan toPromise()bukan subscribe()akan cukup dalam kasus Anda karena toPromise()tidak perlu berhenti berlangganan.

Untuk melengkapi jawaban @ Brandon , menggunakan first()atau sejenisnya juga penting untuk memperbarui BehaviorSubjectberdasarkan Observable. Misalnya (belum diuji):

var subject = new BehaviorSubject({1:'apple',2:'banana'});
var observable = subject.asObservable();

observable
  .pipe(
    first(), // <-- Ensures no stack overflow
    flatMap(function(obj) {
      obj[3] = 'pear';
      return of(obj);
    })
  )
  .subscribe(function(obj) {
    subject.next(obj);
  });

Versi Bersih dan Nyaman

Memperluas jawaban luar biasa M Fuat NUROĞLU tentang mengonversi yang dapat diamati menjadi sebuah janji, inilah versi yang sangat nyaman.

const value = await observable.toPromise();

console.log(value)

Keindahan dari ini adalah bahwa kita dapat menggunakan nilai itu seperti variabel normal tanpa memperkenalkan blok bersarang lain!

Ini sangat berguna ketika Anda perlu mendapatkan beberapa nilai dari beberapa yang bisa diamati. Rapi dan bersih.

const content = await contentObservable.toPromise();
const isAuthenticated = await isAuthenticatedObservable.toPromise();

if(isAuthenticated){
   service.foo(content)
}

Tentu saja, Anda harus membuat fungsi yang mengandung asyncAnda jika Anda ingin pergi dengan rute ini. Anda juga bisa hanya .thenberjanji jika Anda tidak ingin fungsi yang mengandung async

Saya tidak yakin jika ada pengorbanan dengan pendekatan ini, jangan ragu untuk memberi tahu saya di komentar sehingga kami sadar.

PS Jika Anda menyukai jawaban ini, jangan lupa untuk mengunggah Jawaban M Fuat NUROĞLU :)

Saya punya pertanyaan serupa.

Di bawah ini dipanggil bahkan kemudian dari penukar negara yang berbeda. Karena saya tidak mau.

function foo() {
    // this was called many times which was not needed
    observable.subscribe(func);
    changeObservableState("new value");
}

Saya memutuskan untuk mencoba unsubscribe()setelah berlangganan seperti di bawah ini.

function foo() {
    // this was called ONE TIME
    observable.subscribe(func).unsubscribe();
    changeObservableState("new value");
}

subscribe(func).unsubscribe();seperti subscribeOnce(func).

Saya harap itu membantu Anda juga.