ObservableAccessorclass

import { ObservableAccessor } from '@rs-x/core';

import { BehaviorSubject } from 'rxjs';
import {
  InjectionContainer,
  RsXCoreInjectionTokens,
  RsXCoreModule,
  type IObservableAccessor,
} from '@rs-x/core';

await InjectionContainer.load(RsXCoreModule);

const accessor = InjectionContainer.get<IObservableAccessor>(
  RsXCoreInjectionTokens.IObservableAccessor,
);

const model = { stream: new BehaviorSubject<number>(10) };

console.log(accessor.getValue(model, 'stream') instanceof BehaviorSubject); // true
console.log(accessor.getResolvedValue(model, 'stream')); // 10

accessor.setValue(model, 'stream', 11);
console.log(accessor.getResolvedValue(model, 'stream')); // 11

import { Inject, RsXCoreInjectionTokens, type IObservableAccessor } from '@rs-x/core';

class MyConsumer {
  constructor(
    @Inject(RsXCoreInjectionTokens.IObservableAccessor)
    private readonly dependency: IObservableAccessor,
  ) {}
}