streamPositionUpdates

const positions = await client.getOpenPositions({ user: '0xTraderAddress' });
const stream = client.streamPositionUpdates(positions);

stream.onUpdate(next => {
  console.log(next.marginSummary.totalRawPnlUsd);
  console.log(next.pairPositions[0]?.position.unrealizedPnl);
});

stream.onError(err => console.error(err));

await client.openTrade({ /* … */ });

// …once the fill lands
stream.refresh(await client.getOpenPositions({ user: '0xTraderAddress' }));

const priceStream = client.streamPrices([0, 1]);
const positions = await client.getOpenPositions({ user: '0xTraderAddress' });
const stream = client.streamPositionUpdates(positions, priceStream);

interface OstiumPositionUpdatesStream {
  onUpdate(handler: (positions: OpenPositionsResponse) => void): () => void;
  onOpen(handler: () => void): this;
  onError(handler: (event: Error) => void): this;
  onClose(handler: (code: number, reason: string) => void): this;
  getCurrent(): OpenPositionsResponse;
  refresh(next: OpenPositionsResponse): void;
  ingestTick(tick: PriceTick): void;
  ingestSnapshot(ticks: PriceTick[]): void;
  close(): void;
}