feat(account-info-resolver): onPositionExit (#935)

Co-authored-by: CZ <cz@ntnl.io>

common/changes/@yuants/account-info-resolver/2024-12-05-21-03.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@yuants/account-info-resolver",
+      "comment": "sync onPositionExit callback",
+      "type": "minor"
+    }
+  ],
+  "packageName": "@yuants/account-info-resolver"
+}

libraries/account-info-resolver/etc/account-info-resolver.api.md

@@ -16,6 +16,10 @@ export class AccountInfoResolver implements IAccountInfoResolver {
     // (undocumented)
     mapAccountIdToAccountInfo: Map<string, IAccountInfo>;
     // (undocumented)
+    onPositionExit(callback: (position: IPosition) => void): {
+        dispose: () => void;
+    };
+    // (undocumented)
     positionExit$: AsyncIterable<IPosition>;
     // (undocumented)
     updateAccountInfo(accountInfo: IAccountInfo): void;

libraries/account-info-resolver/src/index.ts

@@ -40,6 +40,15 @@ export class AccountInfoResolver implements IAccountInfoResolver {
   private _positionExit$ = new Subject<IPosition>();
   positionExit$: AsyncIterable<IPosition> = observableToAsyncIterable(this._positionExit$);
 
+  onPositionExit(callback: (position: IPosition) => void): { dispose: () => void } {
+    const sub = this._positionExit$.subscribe(callback);
+    return {
+      dispose: () => {
+        sub.unsubscribe();
+      },
+    };
+  }
+
   private dirtyPositions = new Set<IPosition>();
   private dirtyProductIds: Set<string> = new Set();
   private mapProductIdToProduct = new Map<string, IProduct>();

libraries/account-info-resolver/src/model.ts

@@ -11,4 +11,5 @@ export interface IAccountInfoResolver {
 
   mapAccountIdToAccountInfo: ReadonlyMap<string, IAccountInfo>;
   positionExit$: AsyncIterable<IPosition>;
+  onPositionExit: (callback: (position: IPosition) => void) => { dispose: () => void };
 }