import GRPCServer from "./GRPCServer"; import { TypeDaprPubSubCallback } from "../../../types/DaprPubSubCallback.type"; import IServerPubSub from "../../../interfaces/Server/IServerPubSub"; export default class DaprPubSub implements IServerPubSub { server: GRPCServer; private readonly logger; constructor(server: GRPCServer); subscribe(pubSubName: string, topic: string, cb: TypeDaprPubSubCallback): Promise; }