refactor: rm unnecessary share operators

Author: exuanbo

src/app/store/observers/actionObserver.ts

@@ -6,7 +6,7 @@ import {
   type PayloadActionCreator,
   type StoreEnhancer,
 } from '@reduxjs/toolkit'
-import { filter, map, type Observable, share, Subject } from 'rxjs'
+import { filter, map, type Observable, Subject } from 'rxjs'
 
 import { injectStoreExtension } from '../enhancers/injectStoreExtension'
 import { weakMemo } from './weakMemo'
@@ -39,7 +39,6 @@ export const createActionObserver = (): ActionObserver => {
     action$.pipe(
       filter(matchType(actionCreator)),
       map(getPayload),
-      share(),
     ),
   )
 

src/app/store/observers/stateObserver.ts

@@ -1,5 +1,5 @@
 import type { Middleware, Selector, StoreEnhancer } from '@reduxjs/toolkit'
-import { distinctUntilChanged, map, type Observable, ReplaySubject, share, shareReplay } from 'rxjs'
+import { distinctUntilChanged, map, type Observable, ReplaySubject, shareReplay } from 'rxjs'
 
 import { injectStoreExtension } from '../enhancers/injectStoreExtension'
 import { weakMemo } from './weakMemo'
@@ -36,7 +36,6 @@ export const createStateObserver = <State>(): StateObserver<State> => {
     distinctState$.pipe(
       map(selector),
       distinctUntilChanged(),
-      share(),
     ),
   )
 

src/core/bus/bus.ts

@@ -1,4 +1,4 @@
-import { BehaviorSubject, filter, type Observable, share } from 'rxjs'
+import { BehaviorSubject, filter, type Observable } from 'rxjs'
 
 export type Signal = 0b0 | 0b1
 
@@ -31,7 +31,6 @@ export class Bus {
 
   readonly clockRise$: Observable<ControlLines> = this.control$.pipe(
     filter((control, index) => (index && control.CLK)),
-    share(),
   )
 
   setControl(signals: Partial<ControlLines>): void {