Skip to content
Snippets Groups Projects
Commit 767482b0 authored by murgatroid99's avatar murgatroid99
Browse files

Fixed math and stock servers

parent d2785749
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