grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update server to handle default schemes

This commit is contained in:
Michael Lumish 2020-04-21 10:32:58 -07:00
parent 0b522b2289
commit b6846f0709
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/grpc-js/src/server.ts
View File

@ -45,7 +45,7 @@ import {
} from './server-call'; } from './server-call';
import { ServerCredentials } from './server-credentials'; import { ServerCredentials } from './server-credentials';
import { ChannelOptions } from './channel-options'; import { ChannelOptions } from './channel-options';
import { createResolver, ResolverListener } from './resolver'; import { createResolver, ResolverListener, mapUriDefaultScheme } from './resolver';
import { log } from './logging'; import { log } from './logging';
import { import {
SubchannelAddress, SubchannelAddress,
@ -226,10 +226,14 @@ export class Server {
throw new TypeError('callback must be a function'); throw new TypeError('callback must be a function');
} }
const portUri = parseUri(port); const initialPortUri = parseUri(port);
if (portUri === null) { if (initialPortUri === null) {
throw new Error(`Could not parse port "${port}"`); throw new Error(`Could not parse port "${port}"`);
} }
const portUri = mapUriDefaultScheme(initialPortUri);
if (portUri === null) {
throw new Error(`Could not get a default scheme for port "${port}"`);
}
const serverOptions: http2.ServerOptions = {}; const serverOptions: http2.ServerOptions = {};
if ('grpc.max_concurrent_streams' in this.options) { if ('grpc.max_concurrent_streams' in this.options) {