Skip to content
This repository has been archived by the owner on Jun 26, 2023. It is now read-only.

Commit

Permalink
chore: address review
Browse files Browse the repository at this point in the history
  • Loading branch information
vasco-santos committed Aug 19, 2020
1 parent d8671f9 commit e266b17
Showing 1 changed file with 1 addition and 11 deletions.
12 changes: 1 addition & 11 deletions src/pubsub/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -405,7 +405,7 @@ class PubsubBaseProtocol extends EventEmitter {
// Emit to self
this._emitMessage(msg)

this._publishFrom(msg)
this._publish(msg)
}

/**
Expand All @@ -430,16 +430,6 @@ class PubsubBaseProtocol extends EventEmitter {
return utils.msgId(msg.from, msg.seqno)
}

/**
* Process publish message received from a peer
* @abstract
* @param {InMessage} msg
* @returns {void}
*/
_publishFrom (msg) {
throw errcode(new Error('_publishFrom must be implemented by the subclass'), 'ERR_NOT_IMPLEMENTED')
}

/**
* Whether to accept a message from a peer
* Override to create a graylist
Expand Down

0 comments on commit e266b17

Please sign in to comment.