perf: remove callbackToObserve

src/domain/Room.ts

@@ -1,10 +1,10 @@
 import { Remesh } from 'remesh'
-import { map, merge, of, EMPTY, mergeMap, fromEvent, Observable, tap } from 'rxjs'
+import { map, merge, of, EMPTY, mergeMap, fromEvent, Observable, tap, fromEventPattern } from 'rxjs'
 import { NormalMessage, type MessageUser } from './MessageList'
 import { PeerRoomExtern } from '@/domain/externs/PeerRoom'
 import MessageListDomain, { MessageType } from '@/domain/MessageList'
 import UserInfoDomain from '@/domain/UserInfo'
-import { fromEventPattern, desert, upsert } from '@/utils'
+import { desert, upsert } from '@/utils'
 import { nanoid } from 'nanoid'
 import StatusModule from '@/domain/modules/Status'
 

src/utils/callbackToObservable.ts

@@ -1,18 +0,0 @@
-import { Observable } from 'rxjs'
-
-export type Subscribe<T> = (callback: (event: T) => void) => void
-
-const fromEventPattern = <T>(subscribe: Subscribe<T>, unsubscribe?: () => void) => {
-  return new Observable<T>((subscriber) => {
-    subscribe((event: T) => {
-      subscriber.next(event)
-    })
-
-    return () => {
-      unsubscribe?.()
-      subscriber.complete()
-    }
-  })
-}
-
-export default fromEventPattern

src/utils/index.ts

@@ -5,7 +5,6 @@ export { default as getSiteInfo } from './getSiteInfo'
 export { default as compressImage } from './compressImage'
 export { default as isNullish } from './isNullish'
 export { default as checkSystemDarkMode } from './checkSystemDarkMode'
-export { default as fromEventPattern } from './fromEventPattern'
 export { default as stringToHex } from './stringToHex'
 export { default as debounce } from './debounce'
 export { default as throttle } from './throttle'