(err: Error | null, result: any) => {
                      if (err) {
                        logger.error(type, { err });
                      }

                      socket.emit(eventName, err, result && encode(result));
                    },

  send(type: string, value: any[]) {
    logger.debug('emit', { type, value });
    if (this.websocket.isDisconnected()) {
      throw new Error('Websocket is not connected');
    }

    if (!this.resourceName) {
      throw new Error('Invalid resourceName');
    }

    return this.websocket
      .emit('resource', {
        type,
        resourceName: this.resourceName,
        json: encode(value),
      })
      .then((result: any) => result && decode(result));
  }

 .fetch((result: any) =>
   callback(null, result && encode(result)),