mójStrumień.addListener({ // ustaw nasłuchiwacza
  next (event) {
    // wykonaj akcję na kolejne zdarzenie
  },
  error (error) {
    // wykonaj akcję na zdarzenie błędu
  },
  complete () {
    // wykonaj akcję na zdarzenie zakończenia
  },
});