export class Adaptor<Connection extends EE> extends EventMultiplexer<Connection> {

    constructor() {
        super();    
        this.on("close", this.remove);
        this.on("open", this.add);
        this.on("message", onMessage);
    }

    public handleConnection = (c: Connection) => {
        this.emit("open", c);
        return this;
    }
}


function onMessage<C extends EE>(this: Adaptor<C>, remote: C, messages: Buffer) {
    console.log(messages.length)
    const record = decode(messages)
    this.emit("incoming", record, reply)

    function reply(answer: any) {
        // @ts-ignore
        remote.send(encode(answer))
    }
}