/// import { Topic } from '../../topic'; export interface Parser { parseMessage(topic: Topic, payload: Buffer): ParsedMessage[] | ParsedMessage; } export interface ParsedMessage { topic: Topic; data: T; }