nope/lib/observables/nopeRemoteObservable.ts

import { Observable } from 'rxjs';
import { nopeDispatcher } from "../dispatcher/nopeDispatcher";

export type pipe<T, K> = (scope: { [index: string]: any }, observable: Observable<T>) => Observable<K>

export class nopeRemoteObservable<T, S = T, G = T> {
  protected _pathes: {
    get: string,
    set: string,
    subscribe: string,
  }

  /**
   * Creates a Remote Dispatcher.
   * @param _dispatcher 
   * @param options 
   */
  constructor(
    protected _dispatcher: nopeDispatcher,
    public options: {
      path: string,
    }
  ) {

  }

  public get currentRemoteValue() {
    return this.getRemoteValue()
  }

  public async getRemoteValue() {
    return await this._dispatcher.performCall<G>(this._pathes.get, [])
  }

  public async setRemoteValue(value: S) {
    // Perform an Update.
    return await this._dispatcher.performCall<void>(this._pathes.set, [value]);
  }

  /**
   * Function to Subscribe a NopeObservable on a Remote.
   * @param next the callback, which will be called on new Data.
   * @param options 
   */
  public async subscribe<K>(next: (data: K) => void, options: {
    scope?: { [index: string]: any },
    pipe?: pipe<G, K>
  } = {}) {
    return await this._dispatcher.performCall<() => void>(this._pathes.subscribe, [next, options]);
  }
}