On-demand sync with streaming/SSE

 useSubscription(
    trpc.myEndpoint.onSegmentChange.subscriptionOptions(
      { segmentId, languageId },
      {
        onData(data) {           
          if (data.data.type === "initial") {
            for (const exhibit of data.data.exhibits) {
              auctionExhibitsCollection.insert(exhibit);
            }
          } else if (data.data.type === "update") {
            for (const exhibit of data.data.exhibits) {
              auctionExhibitsCollection.update(exhibit.id, (draft) => {
                draft.someProperty = exhibit.someProperty;                 
              });
            }
          }
        },
      },
    )