MCPcopy
hub / github.com/rx-angular/rx-angular / subscribe

Method subscribe

libs/state/src/lib/rx-state.service.ts:1028–1037  ·  view source on GitHub ↗

* @internal

()

Source from the content-addressed store, hash-verified

1026 * @internal
1027 */
1028 subscribe(): Unsubscribable {
1029 const subscription = new Subscription();
1030 subscription.add(this.accumulator.subscribe());
1031 subscription.add(this.effectObservable.subscribe());
1032 this.signalStoreProxy = createSignalStateProxy<State>(
1033 this.$,
1034 this.get.bind(this),
1035 );
1036 return subscription;
1037 }
1038}

Callers 15

constructorMethod · 0.95
revalidateMethod · 0.80
ngAfterViewInitMethod · 0.80
constructorMethod · 0.80
constructorMethod · 0.80
constructorMethod · 0.80
constructorMethod · 0.80
constructorMethod · 0.80
constructorMethod · 0.80
constructorMethod · 0.80
constructorMethod · 0.80
ngAfterViewInitMethod · 0.80

Calls 2

createSignalStateProxyFunction · 0.90
addMethod · 0.45

Tested by 9

constructorMethod · 0.64
constructorMethod · 0.64
constructorMethod · 0.64
renderedFunction · 0.64
renderedFunction · 0.64
createInputStreamFunction · 0.64
createInputStreamFunction · 0.64
ngAfterViewInitMethod · 0.64