import { ISubscriber , IPubSub } from "@fluidframework/server-memory-orderer" ; import { Server } from "socket.io" ; export class PubSubPublisher implements IPubSub { constructor ( private readonly io ) { } public publish ( topic , event , ... args ) { this . io . to ( topic ) . emit ( event , ... args ) ; } public subscribe ( topic , subscriber ) { } public unsubscribe ( topic , subscriber ) { } }