Estoy tratando de tener un observable que se base en un Sujeto, para que se actualice cada vez que el SUbjeto emita.
Por alguna razón, al intentar obtener el valor del observable, el primer valor siempre es nulo y el resto contiene valores. Espero recuperar el último valor emitido del observable. He probado con todo tipo de SUbjects. ¿Qué es lo que me falta?
... activeBookings$: Subject<Booking[]> = new BehaviorSubject<Booking[]>(null); activeBooking$: Observable<Booking> = this.activeBookings$.pipe( filter((bookings) => bookings?.length > 0), mergeMap((bookings) => this.getBookingById(bookings?.[0]?.id)), share() ); i = 0; constructor( public http: HttpClient, public store: Store, public asyncPipe: AsyncPipe, public bookingStoreService: BookingStoreService ) { this.getBookings().subscribe((bookings) => { this.bookings$.next(bookings); }); this.getActiveBookings().subscribe((bookings) => { this.activeBookings$.next(bookings); }); this.getPreviousBookings().subscribe((bookings) => { this.previousBookings$.next(bookings); }); } ...Aquí es donde trato de obtener el último valor:
... const booking: Booking = this.asyncPipe.transform( this.bookingService.activeBooking$ ); booking.status = status; //error: booking is null ...Está utilizando un BehaviorSubject aquí con un valor inicial de nulo:
activeBookings$: Subject<Booking[]> = new BehaviorSubject<Booking[]>(null);Podría inicializarlo con una matriz vacía en su lugar, por ejemplo:
activeBookings$: Subject<Booking[]> = new BehaviorSubject<Booking[]>([]);Sería más consistente en cuanto al tipo, de lo contrario, su tipo real es:
activeBookings$: Subject<Booking[] | null> = new BehaviorSubject<Booking[] | null>(null);¿Por qué te vuelves nulo? Un BehaviorSubject debe inicializarse con un valor y probablemente por eso el primer valor que obtiene es nulo. Un Asunto simple no necesita contener un valor inicial y probablemente no obtendrá un valor nulo
activeBookings$: Subject<Booking[]> = new Subject<Booking[]>()Una forma más limpia de obtener el último valor sin suscribirse a su otro servicio sería aprovechar las funciones de BehaviorSubject y el hecho de que llamar a activeBooking$.value le permite recuperar el último valor de BehaviorSubject. Transforme su campo activeBooking$ para que sea un BehaviorSubject y cuando se suscriba al resultado de getActiveBookings(), podría hacer la computación que está actualmente en la canalización de la definición de activeBooking$ allí y llamar a continuación a activeBooking$ con el resultado y exponer un getter para su otro servicio:
get activeBooking(): Booking { return this.activeBooking$.value }