Skip to content
Snippets Groups Projects
Commit 3c4cb79b authored by Tim Emiola's avatar Tim Emiola
Browse files

Merge pull request #436 from murgatroid99/node_fix_example_servers

Fixed math and stock servers
parents d2785749 767482b0
No related branches found
No related tags found
No related merge requests found
...@@ -128,7 +128,8 @@ var server = new Server({ ...@@ -128,7 +128,8 @@ var server = new Server({
}); });
if (require.main === module) { if (require.main === module) {
server.bind('localhost:7070').listen(); server.bind('0.0.0.0:7070');
server.listen();
} }
/** /**
......
...@@ -35,28 +35,28 @@ package examples; ...@@ -35,28 +35,28 @@ package examples;
message StockRequest { message StockRequest {
optional string symbol = 1; optional string symbol = 1;
optional int32 num_trades_to_watch = 2 [default=0]; optional int32 num_trades_to_watch = 2 [default=0];
}; }
message StockReply { message StockReply {
optional float price = 1; optional float price = 1;
optional string symbol = 2; optional string symbol = 2;
}; }
// Interface exported by the server // Interface exported by the server
service Stock { service Stock {
// Simple blocking RPC // Simple blocking RPC
rpc GetLastTradePrice(StockRequest) returns (StockReply) { rpc GetLastTradePrice(StockRequest) returns (StockReply) {
}; }
// Bidirectional streaming RPC // Bidirectional streaming RPC
rpc GetLastTradePriceMultiple(stream StockRequest) returns rpc GetLastTradePriceMultiple(stream StockRequest) returns
(stream StockReply) { (stream StockReply) {
}; }
// Unidirectional server-to-client streaming RPC // Unidirectional server-to-client streaming RPC
rpc WatchFutureTrades(StockRequest) returns (stream StockReply) { rpc WatchFutureTrades(StockRequest) returns (stream StockReply) {
}; }
// Unidirectional client-to-server streaming RPC // Unidirectional client-to-server streaming RPC
rpc GetHighestTradePrice(stream StockRequest) returns (StockReply) { rpc GetHighestTradePrice(stream StockRequest) returns (StockReply) {
}; }
}; }
\ No newline at end of file \ No newline at end of file
...@@ -35,7 +35,7 @@ var _ = require('underscore'); ...@@ -35,7 +35,7 @@ var _ = require('underscore');
var grpc = require('..'); var grpc = require('..');
var examples = grpc.load(__dirname + '/stock.proto').examples; var examples = grpc.load(__dirname + '/stock.proto').examples;
var StockServer = grpc.makeServerConstructor([examples.Stock.service]); var StockServer = grpc.buildServer([examples.Stock.service]);
function getLastTradePrice(call, callback) { function getLastTradePrice(call, callback) {
callback(null, {price: 88}); callback(null, {price: 88});
...@@ -80,4 +80,9 @@ var stockServer = new StockServer({ ...@@ -80,4 +80,9 @@ var stockServer = new StockServer({
} }
}); });
if (require.main === module) {
stockServer.bind('0.0.0.0:8080');
stockServer.listen();
}
exports.module = stockServer; exports.module = stockServer;
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment