|
|
@ -47,6 +47,7 @@ var Readable = stream.Readable; |
|
|
|
var Writable = stream.Writable; |
|
|
|
var Writable = stream.Writable; |
|
|
|
var Duplex = stream.Duplex; |
|
|
|
var Duplex = stream.Duplex; |
|
|
|
var util = require('util'); |
|
|
|
var util = require('util'); |
|
|
|
|
|
|
|
var version = require('../package.json').version; |
|
|
|
|
|
|
|
|
|
|
|
util.inherits(ClientWritableStream, Writable); |
|
|
|
util.inherits(ClientWritableStream, Writable); |
|
|
|
|
|
|
|
|
|
|
@ -517,9 +518,12 @@ function makeClientConstructor(methods, serviceName) { |
|
|
|
callback(null, metadata); |
|
|
|
callback(null, metadata); |
|
|
|
}; |
|
|
|
}; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if (!options) { |
|
|
|
this.server_address = address.replace(/\/$/, ''); |
|
|
|
options = {}; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
options['grpc.primary_user_agent'] = 'grpc-node/' + version; |
|
|
|
this.channel = new grpc.Channel(address, options); |
|
|
|
this.channel = new grpc.Channel(address, options); |
|
|
|
|
|
|
|
this.server_address = address.replace(/\/$/, ''); |
|
|
|
this.auth_uri = this.server_address + '/' + serviceName; |
|
|
|
this.auth_uri = this.server_address + '/' + serviceName; |
|
|
|
this.updateMetadata = updateMetadata; |
|
|
|
this.updateMetadata = updateMetadata; |
|
|
|
} |
|
|
|
} |
|
|
|