const JsonRpcClientFactory = require("."); const TcpClientProtocol = require("./protocol/tcp"); /** * Creates instance of TcpClientFactory * * @extends JsonRpcClientFactory */ class TcpClientFactory extends JsonRpcClientFactory { constructor(options) { super(options); this.protocol = TcpClientProtocol; } /** @inheritdoc */ buildProtocol() { this.pcolInstance = new this.protocol( this, this.options.version, this.options.delimiter ); } /** @inheritdoc */ end(cb) { this.pcolInstance.end(cb); } /** @inheritdoc */ subscribe(method, cb) { this.on(method, cb); } /** @inheritdoc */ unsubscribe(method, cb) { this.removeListener(method, cb); } /** @inheritdoc */ unsubscribeAll(method) { this.removeAllListeners([method]); } } module.exports = TcpClientFactory;