@ngx-grpc/grpc-web-client
Advanced tools
Comparing version 0.4.3 to 1.0.0
@@ -5,203 +5,20 @@ (function (global, factory) { | ||
(global = global || self, factory((global['ngx-grpc'] = global['ngx-grpc'] || {}, global['ngx-grpc']['grpc-web-client'] = {}), global.ng.core, global.common, global.grpcWeb, global.rxjs)); | ||
}(this, (function (exports, core, common, grpcWeb, rxjs) { 'use strict'; | ||
}(this, (function (exports, i0, common, grpcWeb, rxjs) { 'use strict'; | ||
/*! ***************************************************************************** | ||
Copyright (c) Microsoft Corporation. All rights reserved. | ||
Licensed under the Apache License, Version 2.0 (the "License"); you may not use | ||
this file except in compliance with the License. You may obtain a copy of the | ||
License at http://www.apache.org/licenses/LICENSE-2.0 | ||
/** | ||
* Default configuration for grpc-web clients. Will be used for every GrpcWebClient unless service-specific config is provided | ||
* | ||
* Example: | ||
* | ||
* ``` | ||
* providers: [ | ||
* { provide: GRPC_WEB_CLIENT_DEFAULT_SETTINGS, useClass: { host: 'localhost:4321' } }, | ||
* ] | ||
* ``` | ||
*/ | ||
var GRPC_WEB_CLIENT_DEFAULT_SETTINGS = new i0.InjectionToken('GRPC_WEB_CLIENT_DEFAULT_SETTINGS'); | ||
THIS CODE IS PROVIDED ON AN *AS IS* BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | ||
KIND, EITHER EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION ANY IMPLIED | ||
WARRANTIES OR CONDITIONS OF TITLE, FITNESS FOR A PARTICULAR PURPOSE, | ||
MERCHANTABLITY OR NON-INFRINGEMENT. | ||
See the Apache Version 2.0 License for specific language governing permissions | ||
and limitations under the License. | ||
***************************************************************************** */ | ||
/* global Reflect, Promise */ | ||
var extendStatics = function(d, b) { | ||
extendStatics = Object.setPrototypeOf || | ||
({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || | ||
function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; }; | ||
return extendStatics(d, b); | ||
}; | ||
function __extends(d, b) { | ||
extendStatics(d, b); | ||
function __() { this.constructor = d; } | ||
d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); | ||
} | ||
var __assign = function() { | ||
__assign = Object.assign || function __assign(t) { | ||
for (var s, i = 1, n = arguments.length; i < n; i++) { | ||
s = arguments[i]; | ||
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p)) t[p] = s[p]; | ||
} | ||
return t; | ||
}; | ||
return __assign.apply(this, arguments); | ||
}; | ||
function __rest(s, e) { | ||
var t = {}; | ||
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p) && e.indexOf(p) < 0) | ||
t[p] = s[p]; | ||
if (s != null && typeof Object.getOwnPropertySymbols === "function") | ||
for (var i = 0, p = Object.getOwnPropertySymbols(s); i < p.length; i++) { | ||
if (e.indexOf(p[i]) < 0 && Object.prototype.propertyIsEnumerable.call(s, p[i])) | ||
t[p[i]] = s[p[i]]; | ||
} | ||
return t; | ||
} | ||
function __decorate(decorators, target, key, desc) { | ||
var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d; | ||
if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc); | ||
else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r; | ||
return c > 3 && r && Object.defineProperty(target, key, r), r; | ||
} | ||
function __param(paramIndex, decorator) { | ||
return function (target, key) { decorator(target, key, paramIndex); } | ||
} | ||
function __metadata(metadataKey, metadataValue) { | ||
if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(metadataKey, metadataValue); | ||
} | ||
function __awaiter(thisArg, _arguments, P, generator) { | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
} | ||
function __generator(thisArg, body) { | ||
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g; | ||
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g; | ||
function verb(n) { return function (v) { return step([n, v]); }; } | ||
function step(op) { | ||
if (f) throw new TypeError("Generator is already executing."); | ||
while (_) try { | ||
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t; | ||
if (y = 0, t) op = [op[0] & 2, t.value]; | ||
switch (op[0]) { | ||
case 0: case 1: t = op; break; | ||
case 4: _.label++; return { value: op[1], done: false }; | ||
case 5: _.label++; y = op[1]; op = [0]; continue; | ||
case 7: op = _.ops.pop(); _.trys.pop(); continue; | ||
default: | ||
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; } | ||
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; } | ||
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; } | ||
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; } | ||
if (t[2]) _.ops.pop(); | ||
_.trys.pop(); continue; | ||
} | ||
op = body.call(thisArg, _); | ||
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; } | ||
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true }; | ||
} | ||
} | ||
function __exportStar(m, exports) { | ||
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p]; | ||
} | ||
function __values(o) { | ||
var m = typeof Symbol === "function" && o[Symbol.iterator], i = 0; | ||
if (m) return m.call(o); | ||
return { | ||
next: function () { | ||
if (o && i >= o.length) o = void 0; | ||
return { value: o && o[i++], done: !o }; | ||
} | ||
}; | ||
} | ||
function __read(o, n) { | ||
var m = typeof Symbol === "function" && o[Symbol.iterator]; | ||
if (!m) return o; | ||
var i = m.call(o), r, ar = [], e; | ||
try { | ||
while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value); | ||
} | ||
catch (error) { e = { error: error }; } | ||
finally { | ||
try { | ||
if (r && !r.done && (m = i["return"])) m.call(i); | ||
} | ||
finally { if (e) throw e.error; } | ||
} | ||
return ar; | ||
} | ||
function __spread() { | ||
for (var ar = [], i = 0; i < arguments.length; i++) | ||
ar = ar.concat(__read(arguments[i])); | ||
return ar; | ||
} | ||
function __spreadArrays() { | ||
for (var s = 0, i = 0, il = arguments.length; i < il; i++) s += arguments[i].length; | ||
for (var r = Array(s), k = 0, i = 0; i < il; i++) | ||
for (var a = arguments[i], j = 0, jl = a.length; j < jl; j++, k++) | ||
r[k] = a[j]; | ||
return r; | ||
}; | ||
function __await(v) { | ||
return this instanceof __await ? (this.v = v, this) : new __await(v); | ||
} | ||
function __asyncGenerator(thisArg, _arguments, generator) { | ||
if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined."); | ||
var g = generator.apply(thisArg, _arguments || []), i, q = []; | ||
return i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i; | ||
function verb(n) { if (g[n]) i[n] = function (v) { return new Promise(function (a, b) { q.push([n, v, a, b]) > 1 || resume(n, v); }); }; } | ||
function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } } | ||
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); } | ||
function fulfill(value) { resume("next", value); } | ||
function reject(value) { resume("throw", value); } | ||
function settle(f, v) { if (f(v), q.shift(), q.length) resume(q[0][0], q[0][1]); } | ||
} | ||
function __asyncDelegator(o) { | ||
var i, p; | ||
return i = {}, verb("next"), verb("throw", function (e) { throw e; }), verb("return"), i[Symbol.iterator] = function () { return this; }, i; | ||
function verb(n, f) { i[n] = o[n] ? function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; } : f; } | ||
} | ||
function __asyncValues(o) { | ||
if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined."); | ||
var m = o[Symbol.asyncIterator], i; | ||
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i); | ||
function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; } | ||
function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); } | ||
} | ||
function __makeTemplateObject(cooked, raw) { | ||
if (Object.defineProperty) { Object.defineProperty(cooked, "raw", { value: raw }); } else { cooked.raw = raw; } | ||
return cooked; | ||
}; | ||
function __importStar(mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k]; | ||
result.default = mod; | ||
return result; | ||
} | ||
function __importDefault(mod) { | ||
return (mod && mod.__esModule) ? mod : { default: mod }; | ||
} | ||
var GRPC_WEB_CLIENT_DEFAULT_SETTINGS = new core.InjectionToken('GRPC_WEB_CLIENT_DEFAULT_SETTINGS'); | ||
/** | ||
* GrpcClientFactory implementation based on grpc-web | ||
*/ | ||
var GrpcWebClientFactory = /** @class */ (function () { | ||
@@ -216,16 +33,18 @@ function GrpcWebClientFactory(defaultSettings) { | ||
} | ||
return new GrpcWebClient(__assign({}, settings)); | ||
return new GrpcWebClient(Object.assign({}, settings)); | ||
}; | ||
GrpcWebClientFactory.ctorParameters = function () { return [ | ||
{ type: undefined, decorators: [{ type: core.Optional }, { type: core.Inject, args: [GRPC_WEB_CLIENT_DEFAULT_SETTINGS,] }] } | ||
]; }; | ||
GrpcWebClientFactory.ɵprov = core["ɵɵdefineInjectable"]({ factory: function GrpcWebClientFactory_Factory() { return new GrpcWebClientFactory(core["ɵɵinject"](GRPC_WEB_CLIENT_DEFAULT_SETTINGS, 8)); }, token: GrpcWebClientFactory, providedIn: "root" }); | ||
GrpcWebClientFactory = __decorate([ | ||
core.Injectable({ | ||
providedIn: 'root' | ||
}), | ||
__param(0, core.Optional()), __param(0, core.Inject(GRPC_WEB_CLIENT_DEFAULT_SETTINGS)) | ||
], GrpcWebClientFactory); | ||
return GrpcWebClientFactory; | ||
}()); | ||
GrpcWebClientFactory.ɵprov = i0.ɵɵdefineInjectable({ factory: function GrpcWebClientFactory_Factory() { return new GrpcWebClientFactory(i0.ɵɵinject(GRPC_WEB_CLIENT_DEFAULT_SETTINGS, 8)); }, token: GrpcWebClientFactory, providedIn: "root" }); | ||
GrpcWebClientFactory.decorators = [ | ||
{ type: i0.Injectable, args: [{ | ||
providedIn: 'root' | ||
},] } | ||
]; | ||
GrpcWebClientFactory.ctorParameters = function () { return [ | ||
{ type: undefined, decorators: [{ type: i0.Optional }, { type: i0.Inject, args: [GRPC_WEB_CLIENT_DEFAULT_SETTINGS,] }] } | ||
]; }; | ||
/** | ||
* GrpcClient implementation based on grpc-web | ||
*/ | ||
var GrpcWebClient = /** @class */ (function () { | ||
@@ -239,3 +58,3 @@ function GrpcWebClient(settings) { | ||
return new rxjs.Observable(function (obs) { | ||
var stream = _this.client.rpcCall(_this.settings.host + path, req, metadata || {}, new grpcWeb.AbstractClientBase.MethodInfo(resclss, function (request) { return reqclss.toBinary(request); }, resclss.fromBinary), function (error, data) { | ||
var stream = _this.client.rpcCall(_this.settings.host + path, req, metadata || {}, new grpcWeb.AbstractClientBase.MethodInfo(resclss, function (request) { return request.serializeBinary(); }, resclss.deserializeBinary), function (error, data) { | ||
if (error) { | ||
@@ -258,3 +77,3 @@ obs.next(new common.GrpcStatusEvent(error.code, error.message, error.metadata)); | ||
return new rxjs.Observable(function (obs) { | ||
var stream = _this.client.serverStreaming(_this.settings.host + path, req, metadata || {}, new grpcWeb.AbstractClientBase.MethodInfo(resclss, function (request) { return reqclss.toBinary(request); }, resclss.fromBinary)); | ||
var stream = _this.client.serverStreaming(_this.settings.host + path, req, metadata || {}, new grpcWeb.AbstractClientBase.MethodInfo(resclss, function (request) { return request.serializeBinary(); }, resclss.deserializeBinary)); | ||
stream.on('status', function (status) { return obs.next(new common.GrpcStatusEvent(status.code, status.details, status.metadata)); }); | ||
@@ -273,2 +92,6 @@ stream.on('error', function (error) { | ||
/** | ||
* Generated bundle index. Do not edit. | ||
*/ | ||
exports.GRPC_WEB_CLIENT_DEFAULT_SETTINGS = GRPC_WEB_CLIENT_DEFAULT_SETTINGS; | ||
@@ -275,0 +98,0 @@ exports.GrpcWebClient = GrpcWebClient; |
@@ -1,16 +0,2 @@ | ||
!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("@angular/core"),require("@ngx-grpc/common"),require("grpc-web"),require("rxjs")):"function"==typeof define&&define.amd?define("@ngx-grpc/grpc-web-client",["exports","@angular/core","@ngx-grpc/common","grpc-web","rxjs"],t):t(((e=e||self)["ngx-grpc"]=e["ngx-grpc"]||{},e["ngx-grpc"]["grpc-web-client"]={}),e.ng.core,e.common,e.grpcWeb,e.rxjs)}(this,(function(e,t,n,r,o){"use strict"; | ||
/*! ***************************************************************************** | ||
Copyright (c) Microsoft Corporation. All rights reserved. | ||
Licensed under the Apache License, Version 2.0 (the "License"); you may not use | ||
this file except in compliance with the License. You may obtain a copy of the | ||
License at http://www.apache.org/licenses/LICENSE-2.0 | ||
THIS CODE IS PROVIDED ON AN *AS IS* BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | ||
KIND, EITHER EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION ANY IMPLIED | ||
WARRANTIES OR CONDITIONS OF TITLE, FITNESS FOR A PARTICULAR PURPOSE, | ||
MERCHANTABLITY OR NON-INFRINGEMENT. | ||
See the Apache Version 2.0 License for specific language governing permissions | ||
and limitations under the License. | ||
***************************************************************************** */var c=function(){return(c=Object.assign||function(e){for(var t,n=1,r=arguments.length;n<r;n++)for(var o in t=arguments[n])Object.prototype.hasOwnProperty.call(t,o)&&(e[o]=t[o]);return e}).apply(this,arguments)};function i(e,t){return function(n,r){t(n,r,e)}}var a=new t.InjectionToken("GRPC_WEB_CLIENT_DEFAULT_SETTINGS"),u=function(){function e(e){this.defaultSettings=e}return e.prototype.createClient=function(e,t){var n=t||this.defaultSettings;if(!n)throw new Error("grpc-web client factory: no settings provided for "+e);return new s(c({},n))},e.ctorParameters=function(){return[{type:void 0,decorators:[{type:t.Optional},{type:t.Inject,args:[a]}]}]},e.ɵprov=t["ɵɵdefineInjectable"]({factory:function(){return new e(t["ɵɵinject"](a,8))},token:e,providedIn:"root"}),e=function(e,t,n,r){var o,c=arguments.length,i=c<3?t:null===r?r=Object.getOwnPropertyDescriptor(t,n):r;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)i=Reflect.decorate(e,t,n,r);else for(var a=e.length-1;a>=0;a--)(o=e[a])&&(i=(c<3?o(i):c>3?o(t,n,i):o(t,n))||i);return c>3&&i&&Object.defineProperty(t,n,i),i}([t.Injectable({providedIn:"root"}),i(0,t.Optional()),i(0,t.Inject(a))],e)}(),s=function(){function e(e){this.settings=e,this.client=new r.GrpcWebClientBase(this.settings)}return e.prototype.unary=function(e,t,c,i,a){var u=this;return new o.Observable((function(o){var s=u.client.rpcCall(u.settings.host+e,t,c||{},new r.AbstractClientBase.MethodInfo(a,(function(e){return i.toBinary(e)}),a.fromBinary),(function(e,t){e?(o.next(new n.GrpcStatusEvent(e.code,e.message,e.metadata)),o.complete()):o.next(new n.GrpcDataEvent(t))}));return s.on("status",(function(e){return 0===e.code?o.next(new n.GrpcStatusEvent(e.code,e.details,e.metadata)):null})),s.on("end",(function(){return o.complete()})),function(){return s.cancel()}}))},e.prototype.serverStream=function(e,t,c,i,a){var u=this;return new o.Observable((function(o){var s=u.client.serverStreaming(u.settings.host+e,t,c||{},new r.AbstractClientBase.MethodInfo(a,(function(e){return i.toBinary(e)}),a.fromBinary));return s.on("status",(function(e){return o.next(new n.GrpcStatusEvent(e.code,e.details,e.metadata))})),s.on("error",(function(e){o.next(new n.GrpcStatusEvent(e.code,e.message,e.metadata)),o.complete()})),s.on("data",(function(e){return o.next(new n.GrpcDataEvent(e))})),s.on("end",(function(){return o.complete()})),function(){return s.cancel()}}))},e}();e.GRPC_WEB_CLIENT_DEFAULT_SETTINGS=a,e.GrpcWebClient=s,e.GrpcWebClientFactory=u,Object.defineProperty(e,"__esModule",{value:!0})})); | ||
!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("@angular/core"),require("@ngx-grpc/common"),require("grpc-web"),require("rxjs")):"function"==typeof define&&define.amd?define("@ngx-grpc/grpc-web-client",["exports","@angular/core","@ngx-grpc/common","grpc-web","rxjs"],t):t(((e=e||self)["ngx-grpc"]=e["ngx-grpc"]||{},e["ngx-grpc"]["grpc-web-client"]={}),e.ng.core,e.common,e.grpcWeb,e.rxjs)}(this,(function(e,t,n,r,o){"use strict";var c=new t.InjectionToken("GRPC_WEB_CLIENT_DEFAULT_SETTINGS"),i=function(){function e(e){this.defaultSettings=e}return e.prototype.createClient=function(e,t){var n=t||this.defaultSettings;if(!n)throw new Error("grpc-web client factory: no settings provided for "+e);return new a(Object.assign({},n))},e}();i.ɵprov=t.ɵɵdefineInjectable({factory:function(){return new i(t.ɵɵinject(c,8))},token:i,providedIn:"root"}),i.decorators=[{type:t.Injectable,args:[{providedIn:"root"}]}],i.ctorParameters=function(){return[{type:void 0,decorators:[{type:t.Optional},{type:t.Inject,args:[c]}]}]};var a=function(){function e(e){this.settings=e,this.client=new r.GrpcWebClientBase(this.settings)}return e.prototype.unary=function(e,t,c,i,a){var s=this;return new o.Observable((function(o){var i=s.client.rpcCall(s.settings.host+e,t,c||{},new r.AbstractClientBase.MethodInfo(a,(function(e){return e.serializeBinary()}),a.deserializeBinary),(function(e,t){e?(o.next(new n.GrpcStatusEvent(e.code,e.message,e.metadata)),o.complete()):o.next(new n.GrpcDataEvent(t))}));return i.on("status",(function(e){return 0===e.code?o.next(new n.GrpcStatusEvent(e.code,e.details,e.metadata)):null})),i.on("end",(function(){return o.complete()})),function(){return i.cancel()}}))},e.prototype.serverStream=function(e,t,c,i,a){var s=this;return new o.Observable((function(o){var i=s.client.serverStreaming(s.settings.host+e,t,c||{},new r.AbstractClientBase.MethodInfo(a,(function(e){return e.serializeBinary()}),a.deserializeBinary));return i.on("status",(function(e){return o.next(new n.GrpcStatusEvent(e.code,e.details,e.metadata))})),i.on("error",(function(e){o.next(new n.GrpcStatusEvent(e.code,e.message,e.metadata)),o.complete()})),i.on("data",(function(e){return o.next(new n.GrpcDataEvent(e))})),i.on("end",(function(){return o.complete()})),function(){return i.cancel()}}))},e}();e.GRPC_WEB_CLIENT_DEFAULT_SETTINGS=c,e.GrpcWebClient=a,e.GrpcWebClientFactory=i,Object.defineProperty(e,"__esModule",{value:!0})})); | ||
//# sourceMappingURL=ngx-grpc-grpc-web-client.umd.min.js.map |
@@ -1,2 +0,1 @@ | ||
import { __decorate, __param } from "tslib"; | ||
import { Inject, Injectable, Optional } from '@angular/core'; | ||
@@ -9,3 +8,6 @@ import { GrpcDataEvent, GrpcStatusEvent } from '@ngx-grpc/common'; | ||
import * as i1 from "./tokens"; | ||
let GrpcWebClientFactory = class GrpcWebClientFactory { | ||
/** | ||
* GrpcClientFactory implementation based on grpc-web | ||
*/ | ||
export class GrpcWebClientFactory { | ||
constructor(defaultSettings) { | ||
@@ -21,14 +23,15 @@ this.defaultSettings = defaultSettings; | ||
} | ||
}; | ||
} | ||
GrpcWebClientFactory.ɵprov = i0.ɵɵdefineInjectable({ factory: function GrpcWebClientFactory_Factory() { return new GrpcWebClientFactory(i0.ɵɵinject(i1.GRPC_WEB_CLIENT_DEFAULT_SETTINGS, 8)); }, token: GrpcWebClientFactory, providedIn: "root" }); | ||
GrpcWebClientFactory.decorators = [ | ||
{ type: Injectable, args: [{ | ||
providedIn: 'root' | ||
},] } | ||
]; | ||
GrpcWebClientFactory.ctorParameters = () => [ | ||
{ type: undefined, decorators: [{ type: Optional }, { type: Inject, args: [GRPC_WEB_CLIENT_DEFAULT_SETTINGS,] }] } | ||
]; | ||
GrpcWebClientFactory.ɵprov = i0.ɵɵdefineInjectable({ factory: function GrpcWebClientFactory_Factory() { return new GrpcWebClientFactory(i0.ɵɵinject(i1.GRPC_WEB_CLIENT_DEFAULT_SETTINGS, 8)); }, token: GrpcWebClientFactory, providedIn: "root" }); | ||
GrpcWebClientFactory = __decorate([ | ||
Injectable({ | ||
providedIn: 'root' | ||
}), | ||
__param(0, Optional()), __param(0, Inject(GRPC_WEB_CLIENT_DEFAULT_SETTINGS)) | ||
], GrpcWebClientFactory); | ||
export { GrpcWebClientFactory }; | ||
/** | ||
* GrpcClient implementation based on grpc-web | ||
*/ | ||
export class GrpcWebClient { | ||
@@ -41,3 +44,3 @@ constructor(settings) { | ||
return new Observable(obs => { | ||
const stream = this.client.rpcCall(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => reqclss.toBinary(request), resclss.fromBinary), (error, data) => { | ||
const stream = this.client.rpcCall(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => request.serializeBinary(), resclss.deserializeBinary), (error, data) => { | ||
if (error) { | ||
@@ -59,3 +62,3 @@ obs.next(new GrpcStatusEvent(error.code, error.message, error.metadata)); | ||
return new Observable(obs => { | ||
const stream = this.client.serverStreaming(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => reqclss.toBinary(request), resclss.fromBinary)); | ||
const stream = this.client.serverStreaming(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => request.serializeBinary(), resclss.deserializeBinary)); | ||
stream.on('status', status => obs.next(new GrpcStatusEvent(status.code, status.details, status.metadata))); | ||
@@ -72,2 +75,2 @@ stream.on('error', error => { | ||
} | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZ3JwYy13ZWItY2xpZW50LmpzIiwic291cmNlUm9vdCI6Im5nOi8vQG5neC1ncnBjL2dycGMtd2ViLWNsaWVudC8iLCJzb3VyY2VzIjpbImxpYi9ncnBjLXdlYi1jbGllbnQudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLE9BQU8sRUFBRSxNQUFNLEVBQUUsVUFBVSxFQUFFLFFBQVEsRUFBRSxNQUFNLGVBQWUsQ0FBQztBQUM3RCxPQUFPLEVBQXFELGFBQWEsRUFBNEMsZUFBZSxFQUFFLE1BQU0sa0JBQWtCLENBQUM7QUFDL0osT0FBTyxFQUFFLGtCQUFrQixFQUFFLGlCQUFpQixFQUFZLE1BQU0sVUFBVSxDQUFDO0FBQzNFLE9BQU8sRUFBRSxVQUFVLEVBQUUsTUFBTSxNQUFNLENBQUM7QUFDbEMsT0FBTyxFQUFFLGdDQUFnQyxFQUFFLE1BQU0sVUFBVSxDQUFDOzs7QUFLNUQsSUFBYSxvQkFBb0IsR0FBakMsTUFBYSxvQkFBb0I7SUFFL0IsWUFDZ0UsZUFBbUM7UUFBbkMsb0JBQWUsR0FBZixlQUFlLENBQW9CO0lBQy9GLENBQUM7SUFFTCxZQUFZLENBQUMsU0FBaUIsRUFBRSxjQUFrQztRQUNoRSxNQUFNLFFBQVEsR0FBRyxjQUFjLElBQUksSUFBSSxDQUFDLGVBQWUsQ0FBQztRQUV4RCxJQUFJLENBQUMsUUFBUSxFQUFFO1lBQ2IsTUFBTSxJQUFJLEtBQUssQ0FBQyxxREFBcUQsU0FBUyxFQUFFLENBQUMsQ0FBQztTQUNuRjtRQUVELE9BQU8sSUFBSSxhQUFhLG1CQUFNLFFBQVEsRUFBRyxDQUFDO0lBQzVDLENBQUM7Q0FFRixDQUFBOzs0Q0FiSSxRQUFRLFlBQUksTUFBTSxTQUFDLGdDQUFnQzs7O0FBSDNDLG9CQUFvQjtJQUhoQyxVQUFVLENBQUM7UUFDVixVQUFVLEVBQUUsTUFBTTtLQUNuQixDQUFDO0lBSUcsV0FBQSxRQUFRLEVBQUUsQ0FBQSxFQUFFLFdBQUEsTUFBTSxDQUFDLGdDQUFnQyxDQUFDLENBQUE7R0FINUMsb0JBQW9CLENBZ0JoQztTQWhCWSxvQkFBb0I7QUFrQmpDLE1BQU0sT0FBTyxhQUFhO0lBSXhCLFlBQ1UsUUFBNEI7UUFBNUIsYUFBUSxHQUFSLFFBQVEsQ0FBb0I7UUFFcEMsSUFBSSxDQUFDLE1BQU0sR0FBRyxJQUFJLGlCQUFpQixDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQztJQUNyRCxDQUFDO0lBRUQsS0FBSyxDQUNILElBQVksRUFDWixHQUFNLEVBQ04sUUFBa0IsRUFDbEIsT0FBNEIsRUFDNUIsT0FBNEI7UUFFNUIsT0FBTyxJQUFJLFVBQVUsQ0FBQyxHQUFHLENBQUMsRUFBRTtZQUMxQixNQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FDaEMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxJQUFJLEdBQUcsSUFBSSxFQUN6QixHQUFHLEVBQ0gsUUFBUSxJQUFJLEVBQUUsRUFDZCxJQUFJLGtCQUFrQixDQUFDLFVBQVUsQ0FDL0IsT0FBTyxFQUNQLENBQUMsT0FBVSxFQUFFLEVBQUUsQ0FBQyxPQUFPLENBQUMsUUFBUSxDQUFDLE9BQU8sQ0FBQyxFQUN6QyxPQUFPLENBQUMsVUFBVSxDQUNuQixFQUNELENBQUMsS0FBSyxFQUFFLElBQUksRUFBRSxFQUFFO2dCQUNkLElBQUksS0FBSyxFQUFFO29CQUNULEdBQUcsQ0FBQyxJQUFJLENBQUMsSUFBSSxlQUFlLENBQUMsS0FBSyxDQUFDLElBQUksRUFBRSxLQUFLLENBQUMsT0FBTyxFQUFHLEtBQWEsQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDO29CQUNsRixHQUFHLENBQUMsUUFBUSxFQUFFLENBQUM7aUJBQ2hCO3FCQUFNO29CQUNMLEdBQUcsQ0FBQyxJQUFJLENBQUMsSUFBSSxhQUFhLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQztpQkFDbkM7WUFDSCxDQUFDLENBQ0YsQ0FBQztZQUVGLDRFQUE0RTtZQUM1RSxNQUFNLENBQUMsRUFBRSxDQUFDLFFBQVEsRUFBRSxNQUFNLENBQUMsRUFBRSxDQUFDLE1BQU0sQ0FBQyxJQUFJLEtBQUssQ0FBQyxDQUFDLENBQUMsQ0FBQyxHQUFHLENBQUMsSUFBSSxDQUFDLElBQUksZUFBZSxDQUFDLE1BQU0sQ0FBQyxJQUFJLEVBQUUsTUFBTSxDQUFDLE9BQU8sRUFBRSxNQUFNLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsSUFBSSxDQUFDLENBQUM7WUFDdEksTUFBTSxDQUFDLEVBQUUsQ0FBQyxLQUFLLEVBQUUsR0FBRyxFQUFFLENBQUMsR0FBRyxDQUFDLFFBQVEsRUFBRSxDQUFDLENBQUM7WUFFdkMsT0FBTyxHQUFHLEVBQUUsQ0FBQyxNQUFNLENBQUMsTUFBTSxFQUFFLENBQUM7UUFDL0IsQ0FBQyxDQUFDLENBQUM7SUFDTCxDQUFDO0lBRUQsWUFBWSxDQUNWLElBQVksRUFDWixHQUFNLEVBQ04sUUFBa0IsRUFDbEIsT0FBNEIsRUFDNUIsT0FBNEI7UUFFNUIsT0FBTyxJQUFJLFVBQVUsQ0FBQyxHQUFHLENBQUMsRUFBRTtZQUMxQixNQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsTUFBTSxDQUFDLGVBQWUsQ0FDeEMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxJQUFJLEdBQUcsSUFBSSxFQUN6QixHQUFHLEVBQ0gsUUFBUSxJQUFJLEVBQUUsRUFDZCxJQUFJLGtCQUFrQixDQUFDLFVBQVUsQ0FBQyxPQUFPLEVBQUUsQ0FBQyxPQUFVLEVBQUUsRUFBRSxDQUFDLE9BQU8sQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLEVBQUUsT0FBTyxDQUFDLFVBQVUsQ0FBQyxDQUMxRyxDQUFDO1lBRUYsTUFBTSxDQUFDLEVBQUUsQ0FBQyxRQUFRLEVBQUUsTUFBTSxDQUFDLEVBQUUsQ0FBQyxHQUFHLENBQUMsSUFBSSxDQUFDLElBQUksZUFBZSxDQUFDLE1BQU0sQ0FBQyxJQUFJLEVBQUUsTUFBTSxDQUFDLE9BQU8sRUFBRSxNQUFNLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQyxDQUFDO1lBQzNHLE1BQU0sQ0FBQyxFQUFFLENBQUMsT0FBTyxFQUFFLEtBQUssQ0FBQyxFQUFFO2dCQUN6QixHQUFHLENBQUMsSUFBSSxDQUFDLElBQUksZUFBZSxDQUFDLEtBQUssQ0FBQyxJQUFJLEVBQUUsS0FBSyxDQUFDLE9BQU8sRUFBRyxLQUFhLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztnQkFDbEYsR0FBRyxDQUFDLFFBQVEsRUFBRSxDQUFDO1lBQ2pCLENBQUMsQ0FBQyxDQUFDO1lBQ0gsTUFBTSxDQUFDLEVBQUUsQ0FBQyxNQUFNLEVBQUUsSUFBSSxDQUFDLEVBQUUsQ0FBQyxHQUFHLENBQUMsSUFBSSxDQUFDLElBQUksYUFBYSxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUMsQ0FBQztZQUM3RCxNQUFNLENBQUMsRUFBRSxDQUFDLEtBQUssRUFBRSxHQUFHLEVBQUUsQ0FBQyxHQUFHLENBQUMsUUFBUSxFQUFFLENBQUMsQ0FBQztZQUV2QyxPQUFPLEdBQUcsRUFBRSxDQUFDLE1BQU0sQ0FBQyxNQUFNLEVBQUUsQ0FBQztRQUMvQixDQUFDLENBQUMsQ0FBQztJQUNMLENBQUM7Q0FFRiIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEluamVjdCwgSW5qZWN0YWJsZSwgT3B0aW9uYWwgfSBmcm9tICdAYW5ndWxhci9jb3JlJztcbmltcG9ydCB7IEdycGNDbGllbnQsIEdycGNDbGllbnRGYWN0b3J5LCBHcnBjQ2xpZW50U2V0dGluZ3MsIEdycGNEYXRhRXZlbnQsIEdycGNFdmVudCwgR3JwY01lc3NhZ2UsIEdycGNNZXNzYWdlQ2xhc3MsIEdycGNTdGF0dXNFdmVudCB9IGZyb20gJ0BuZ3gtZ3JwYy9jb21tb24nO1xuaW1wb3J0IHsgQWJzdHJhY3RDbGllbnRCYXNlLCBHcnBjV2ViQ2xpZW50QmFzZSwgTWV0YWRhdGEgfSBmcm9tICdncnBjLXdlYic7XG5pbXBvcnQgeyBPYnNlcnZhYmxlIH0gZnJvbSAncnhqcyc7XG5pbXBvcnQgeyBHUlBDX1dFQl9DTElFTlRfREVGQVVMVF9TRVRUSU5HUyB9IGZyb20gJy4vdG9rZW5zJztcblxuQEluamVjdGFibGUoe1xuICBwcm92aWRlZEluOiAncm9vdCdcbn0pXG5leHBvcnQgY2xhc3MgR3JwY1dlYkNsaWVudEZhY3RvcnkgaW1wbGVtZW50cyBHcnBjQ2xpZW50RmFjdG9yeSB7XG5cbiAgY29uc3RydWN0b3IoXG4gICAgQE9wdGlvbmFsKCkgQEluamVjdChHUlBDX1dFQl9DTElFTlRfREVGQVVMVF9TRVRUSU5HUykgcHJpdmF0ZSBkZWZhdWx0U2V0dGluZ3M6IEdycGNDbGllbnRTZXR0aW5ncyxcbiAgKSB7IH1cblxuICBjcmVhdGVDbGllbnQoc2VydmljZUlkOiBzdHJpbmcsIGN1c3RvbVNldHRpbmdzOiBHcnBjQ2xpZW50U2V0dGluZ3MpIHtcbiAgICBjb25zdCBzZXR0aW5ncyA9IGN1c3RvbVNldHRpbmdzIHx8IHRoaXMuZGVmYXVsdFNldHRpbmdzO1xuXG4gICAgaWYgKCFzZXR0aW5ncykge1xuICAgICAgdGhyb3cgbmV3IEVycm9yKGBncnBjLXdlYiBjbGllbnQgZmFjdG9yeTogbm8gc2V0dGluZ3MgcHJvdmlkZWQgZm9yICR7c2VydmljZUlkfWApO1xuICAgIH1cblxuICAgIHJldHVybiBuZXcgR3JwY1dlYkNsaWVudCh7IC4uLnNldHRpbmdzIH0pO1xuICB9XG5cbn1cblxuZXhwb3J0IGNsYXNzIEdycGNXZWJDbGllbnQgaW1wbGVtZW50cyBHcnBjQ2xpZW50IHtcblxuICBwcml2YXRlIGNsaWVudDogR3JwY1dlYkNsaWVudEJhc2U7XG5cbiAgY29uc3RydWN0b3IoXG4gICAgcHJpdmF0ZSBzZXR0aW5nczogR3JwY0NsaWVudFNldHRpbmdzLFxuICApIHtcbiAgICB0aGlzLmNsaWVudCA9IG5ldyBHcnBjV2ViQ2xpZW50QmFzZSh0aGlzLnNldHRpbmdzKTtcbiAgfVxuXG4gIHVuYXJ5PFEgZXh0ZW5kcyBHcnBjTWVzc2FnZSwgUyBleHRlbmRzIEdycGNNZXNzYWdlPihcbiAgICBwYXRoOiBzdHJpbmcsXG4gICAgcmVxOiBRLFxuICAgIG1ldGFkYXRhOiBNZXRhZGF0YSxcbiAgICByZXFjbHNzOiBHcnBjTWVzc2FnZUNsYXNzPFE+LFxuICAgIHJlc2Nsc3M6IEdycGNNZXNzYWdlQ2xhc3M8Uz4sXG4gICk6IE9ic2VydmFibGU8R3JwY0V2ZW50PFM+PiB7XG4gICAgcmV0dXJuIG5ldyBPYnNlcnZhYmxlKG9icyA9PiB7XG4gICAgICBjb25zdCBzdHJlYW0gPSB0aGlzLmNsaWVudC5ycGNDYWxsKFxuICAgICAgICB0aGlzLnNldHRpbmdzLmhvc3QgKyBwYXRoLFxuICAgICAgICByZXEsXG4gICAgICAgIG1ldGFkYXRhIHx8IHt9LFxuICAgICAgICBuZXcgQWJzdHJhY3RDbGllbnRCYXNlLk1ldGhvZEluZm8oXG4gICAgICAgICAgcmVzY2xzcyxcbiAgICAgICAgICAocmVxdWVzdDogUSkgPT4gcmVxY2xzcy50b0JpbmFyeShyZXF1ZXN0KSxcbiAgICAgICAgICByZXNjbHNzLmZyb21CaW5hcnlcbiAgICAgICAgKSxcbiAgICAgICAgKGVycm9yLCBkYXRhKSA9PiB7XG4gICAgICAgICAgaWYgKGVycm9yKSB7XG4gICAgICAgICAgICBvYnMubmV4dChuZXcgR3JwY1N0YXR1c0V2ZW50KGVycm9yLmNvZGUsIGVycm9yLm1lc3NhZ2UsIChlcnJvciBhcyBhbnkpLm1ldGFkYXRhKSk7XG4gICAgICAgICAgICBvYnMuY29tcGxldGUoKTtcbiAgICAgICAgICB9IGVsc2Uge1xuICAgICAgICAgICAgb2JzLm5leHQobmV3IEdycGNEYXRhRXZlbnQoZGF0YSkpO1xuICAgICAgICAgIH1cbiAgICAgICAgfVxuICAgICAgKTtcblxuICAgICAgLy8gdGFrZSBvbmx5IHN0YXR1cyAwIGJlY2F1c2UgdW5hcnkgZXJyb3IgYWxyZWFkeSBpbmNsdWRlcyBub24temVybyBzdGF0dXNlc1xuICAgICAgc3RyZWFtLm9uKCdzdGF0dXMnLCBzdGF0dXMgPT4gc3RhdHVzLmNvZGUgPT09IDAgPyBvYnMubmV4dChuZXcgR3JwY1N0YXR1c0V2ZW50KHN0YXR1cy5jb2RlLCBzdGF0dXMuZGV0YWlscywgc3RhdHVzLm1ldGFkYXRhKSkgOiBudWxsKTtcbiAgICAgIHN0cmVhbS5vbignZW5kJywgKCkgPT4gb2JzLmNvbXBsZXRlKCkpO1xuXG4gICAgICByZXR1cm4gKCkgPT4gc3RyZWFtLmNhbmNlbCgpO1xuICAgIH0pO1xuICB9XG5cbiAgc2VydmVyU3RyZWFtPFEgZXh0ZW5kcyBHcnBjTWVzc2FnZSwgUyBleHRlbmRzIEdycGNNZXNzYWdlPihcbiAgICBwYXRoOiBzdHJpbmcsXG4gICAgcmVxOiBRLFxuICAgIG1ldGFkYXRhOiBNZXRhZGF0YSxcbiAgICByZXFjbHNzOiBHcnBjTWVzc2FnZUNsYXNzPFE+LFxuICAgIHJlc2Nsc3M6IEdycGNNZXNzYWdlQ2xhc3M8Uz5cbiAgKTogT2JzZXJ2YWJsZTxHcnBjRXZlbnQ8Uz4+IHtcbiAgICByZXR1cm4gbmV3IE9ic2VydmFibGUob2JzID0+IHtcbiAgICAgIGNvbnN0IHN0cmVhbSA9IHRoaXMuY2xpZW50LnNlcnZlclN0cmVhbWluZyhcbiAgICAgICAgdGhpcy5zZXR0aW5ncy5ob3N0ICsgcGF0aCxcbiAgICAgICAgcmVxLFxuICAgICAgICBtZXRhZGF0YSB8fCB7fSxcbiAgICAgICAgbmV3IEFic3RyYWN0Q2xpZW50QmFzZS5NZXRob2RJbmZvKHJlc2Nsc3MsIChyZXF1ZXN0OiBRKSA9PiByZXFjbHNzLnRvQmluYXJ5KHJlcXVlc3QpLCByZXNjbHNzLmZyb21CaW5hcnkpXG4gICAgICApO1xuXG4gICAgICBzdHJlYW0ub24oJ3N0YXR1cycsIHN0YXR1cyA9PiBvYnMubmV4dChuZXcgR3JwY1N0YXR1c0V2ZW50KHN0YXR1cy5jb2RlLCBzdGF0dXMuZGV0YWlscywgc3RhdHVzLm1ldGFkYXRhKSkpO1xuICAgICAgc3RyZWFtLm9uKCdlcnJvcicsIGVycm9yID0+IHtcbiAgICAgICAgb2JzLm5leHQobmV3IEdycGNTdGF0dXNFdmVudChlcnJvci5jb2RlLCBlcnJvci5tZXNzYWdlLCAoZXJyb3IgYXMgYW55KS5tZXRhZGF0YSkpO1xuICAgICAgICBvYnMuY29tcGxldGUoKTtcbiAgICAgIH0pO1xuICAgICAgc3RyZWFtLm9uKCdkYXRhJywgZGF0YSA9PiBvYnMubmV4dChuZXcgR3JwY0RhdGFFdmVudChkYXRhKSkpO1xuICAgICAgc3RyZWFtLm9uKCdlbmQnLCAoKSA9PiBvYnMuY29tcGxldGUoKSk7XG5cbiAgICAgIHJldHVybiAoKSA9PiBzdHJlYW0uY2FuY2VsKCk7XG4gICAgfSk7XG4gIH1cblxufVxuIl19 | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZ3JwYy13ZWItY2xpZW50LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vcGFja2FnZXMvZ3JwYy13ZWItY2xpZW50L3NyYy9saWIvZ3JwYy13ZWItY2xpZW50LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE9BQU8sRUFBRSxNQUFNLEVBQUUsVUFBVSxFQUFFLFFBQVEsRUFBRSxNQUFNLGVBQWUsQ0FBQztBQUM3RCxPQUFPLEVBQXFELGFBQWEsRUFBNEMsZUFBZSxFQUFFLE1BQU0sa0JBQWtCLENBQUM7QUFDL0osT0FBTyxFQUFFLGtCQUFrQixFQUFFLGlCQUFpQixFQUFZLE1BQU0sVUFBVSxDQUFDO0FBQzNFLE9BQU8sRUFBRSxVQUFVLEVBQUUsTUFBTSxNQUFNLENBQUM7QUFDbEMsT0FBTyxFQUFFLGdDQUFnQyxFQUFFLE1BQU0sVUFBVSxDQUFDOzs7QUFFNUQ7O0dBRUc7QUFJSCxNQUFNLE9BQU8sb0JBQW9CO0lBRS9CLFlBQ2dFLGVBQW1DO1FBQW5DLG9CQUFlLEdBQWYsZUFBZSxDQUFvQjtJQUMvRixDQUFDO0lBRUwsWUFBWSxDQUFDLFNBQWlCLEVBQUUsY0FBa0M7UUFDaEUsTUFBTSxRQUFRLEdBQUcsY0FBYyxJQUFJLElBQUksQ0FBQyxlQUFlLENBQUM7UUFFeEQsSUFBSSxDQUFDLFFBQVEsRUFBRTtZQUNiLE1BQU0sSUFBSSxLQUFLLENBQUMscURBQXFELFNBQVMsRUFBRSxDQUFDLENBQUM7U0FDbkY7UUFFRCxPQUFPLElBQUksYUFBYSxtQkFBTSxRQUFRLEVBQUcsQ0FBQztJQUM1QyxDQUFDOzs7O1lBakJGLFVBQVUsU0FBQztnQkFDVixVQUFVLEVBQUUsTUFBTTthQUNuQjs7OzRDQUlJLFFBQVEsWUFBSSxNQUFNLFNBQUMsZ0NBQWdDOztBQWV4RDs7R0FFRztBQUNILE1BQU0sT0FBTyxhQUFhO0lBSXhCLFlBQ1UsUUFBNEI7UUFBNUIsYUFBUSxHQUFSLFFBQVEsQ0FBb0I7UUFFcEMsSUFBSSxDQUFDLE1BQU0sR0FBRyxJQUFJLGlCQUFpQixDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQztJQUNyRCxDQUFDO0lBRUQsS0FBSyxDQUNILElBQVksRUFDWixHQUFNLEVBQ04sUUFBa0IsRUFDbEIsT0FBNEIsRUFDNUIsT0FBNEI7UUFFNUIsT0FBTyxJQUFJLFVBQVUsQ0FBQyxHQUFHLENBQUMsRUFBRTtZQUMxQixNQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FDaEMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxJQUFJLEdBQUcsSUFBSSxFQUN6QixHQUFHLEVBQ0gsUUFBUSxJQUFJLEVBQUUsRUFDZCxJQUFJLGtCQUFrQixDQUFDLFVBQVUsQ0FDL0IsT0FBTyxFQUNQLENBQUMsT0FBVSxFQUFFLEVBQUUsQ0FBQyxPQUFPLENBQUMsZUFBZSxFQUFFLEVBQ3pDLE9BQU8sQ0FBQyxpQkFBaUIsQ0FDMUIsRUFDRCxDQUFDLEtBQUssRUFBRSxJQUFJLEVBQUUsRUFBRTtnQkFDZCxJQUFJLEtBQUssRUFBRTtvQkFDVCxHQUFHLENBQUMsSUFBSSxDQUFDLElBQUksZUFBZSxDQUFDLEtBQUssQ0FBQyxJQUFJLEVBQUUsS0FBSyxDQUFDLE9BQU8sRUFBRyxLQUFhLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztvQkFDbEYsR0FBRyxDQUFDLFFBQVEsRUFBRSxDQUFDO2lCQUNoQjtxQkFBTTtvQkFDTCxHQUFHLENBQUMsSUFBSSxDQUFDLElBQUksYUFBYSxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUM7aUJBQ25DO1lBQ0gsQ0FBQyxDQUNGLENBQUM7WUFFRiw0RUFBNEU7WUFDNUUsTUFBTSxDQUFDLEVBQUUsQ0FBQyxRQUFRLEVBQUUsTUFBTSxDQUFDLEVBQUUsQ0FBQyxNQUFNLENBQUMsSUFBSSxLQUFLLENBQUMsQ0FBQyxDQUFDLENBQUMsR0FBRyxDQUFDLElBQUksQ0FBQyxJQUFJLGVBQWUsQ0FBQyxNQUFNLENBQUMsSUFBSSxFQUFFLE1BQU0sQ0FBQyxPQUFPLEVBQUUsTUFBTSxDQUFDLFFBQVEsQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxDQUFDO1lBQ3RJLE1BQU0sQ0FBQyxFQUFFLENBQUMsS0FBSyxFQUFFLEdBQUcsRUFBRSxDQUFDLEdBQUcsQ0FBQyxRQUFRLEVBQUUsQ0FBQyxDQUFDO1lBRXZDLE9BQU8sR0FBRyxFQUFFLENBQUMsTUFBTSxDQUFDLE1BQU0sRUFBRSxDQUFDO1FBQy9CLENBQUMsQ0FBQyxDQUFDO0lBQ0wsQ0FBQztJQUVELFlBQVksQ0FDVixJQUFZLEVBQ1osR0FBTSxFQUNOLFFBQWtCLEVBQ2xCLE9BQTRCLEVBQzVCLE9BQTRCO1FBRTVCLE9BQU8sSUFBSSxVQUFVLENBQUMsR0FBRyxDQUFDLEVBQUU7WUFDMUIsTUFBTSxNQUFNLEdBQUcsSUFBSSxDQUFDLE1BQU0sQ0FBQyxlQUFlLENBQ3hDLElBQUksQ0FBQyxRQUFRLENBQUMsSUFBSSxHQUFHLElBQUksRUFDekIsR0FBRyxFQUNILFFBQVEsSUFBSSxFQUFFLEVBQ2QsSUFBSSxrQkFBa0IsQ0FBQyxVQUFVLENBQUMsT0FBTyxFQUFFLENBQUMsT0FBVSxFQUFFLEVBQUUsQ0FBQyxPQUFPLENBQUMsZUFBZSxFQUFFLEVBQUUsT0FBTyxDQUFDLGlCQUFpQixDQUFDLENBQ2pILENBQUM7WUFFRixNQUFNLENBQUMsRUFBRSxDQUFDLFFBQVEsRUFBRSxNQUFNLENBQUMsRUFBRSxDQUFDLEdBQUcsQ0FBQyxJQUFJLENBQUMsSUFBSSxlQUFlLENBQUMsTUFBTSxDQUFDLElBQUksRUFBRSxNQUFNLENBQUMsT0FBTyxFQUFFLE1BQU0sQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDLENBQUM7WUFDM0csTUFBTSxDQUFDLEVBQUUsQ0FBQyxPQUFPLEVBQUUsS0FBSyxDQUFDLEVBQUU7Z0JBQ3pCLEdBQUcsQ0FBQyxJQUFJLENBQUMsSUFBSSxlQUFlLENBQUMsS0FBSyxDQUFDLElBQUksRUFBRSxLQUFLLENBQUMsT0FBTyxFQUFHLEtBQWEsQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDO2dCQUNsRixHQUFHLENBQUMsUUFBUSxFQUFFLENBQUM7WUFDakIsQ0FBQyxDQUFDLENBQUM7WUFDSCxNQUFNLENBQUMsRUFBRSxDQUFDLE1BQU0sRUFBRSxJQUFJLENBQUMsRUFBRSxDQUFDLEdBQUcsQ0FBQyxJQUFJLENBQUMsSUFBSSxhQUFhLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQyxDQUFDO1lBQzdELE1BQU0sQ0FBQyxFQUFFLENBQUMsS0FBSyxFQUFFLEdBQUcsRUFBRSxDQUFDLEdBQUcsQ0FBQyxRQUFRLEVBQUUsQ0FBQyxDQUFDO1lBRXZDLE9BQU8sR0FBRyxFQUFFLENBQUMsTUFBTSxDQUFDLE1BQU0sRUFBRSxDQUFDO1FBQy9CLENBQUMsQ0FBQyxDQUFDO0lBQ0wsQ0FBQztDQUVGIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSW5qZWN0LCBJbmplY3RhYmxlLCBPcHRpb25hbCB9IGZyb20gJ0Bhbmd1bGFyL2NvcmUnO1xuaW1wb3J0IHsgR3JwY0NsaWVudCwgR3JwY0NsaWVudEZhY3RvcnksIEdycGNDbGllbnRTZXR0aW5ncywgR3JwY0RhdGFFdmVudCwgR3JwY0V2ZW50LCBHcnBjTWVzc2FnZSwgR3JwY01lc3NhZ2VDbGFzcywgR3JwY1N0YXR1c0V2ZW50IH0gZnJvbSAnQG5neC1ncnBjL2NvbW1vbic7XG5pbXBvcnQgeyBBYnN0cmFjdENsaWVudEJhc2UsIEdycGNXZWJDbGllbnRCYXNlLCBNZXRhZGF0YSB9IGZyb20gJ2dycGMtd2ViJztcbmltcG9ydCB7IE9ic2VydmFibGUgfSBmcm9tICdyeGpzJztcbmltcG9ydCB7IEdSUENfV0VCX0NMSUVOVF9ERUZBVUxUX1NFVFRJTkdTIH0gZnJvbSAnLi90b2tlbnMnO1xuXG4vKipcbiAqIEdycGNDbGllbnRGYWN0b3J5IGltcGxlbWVudGF0aW9uIGJhc2VkIG9uIGdycGMtd2ViXG4gKi9cbkBJbmplY3RhYmxlKHtcbiAgcHJvdmlkZWRJbjogJ3Jvb3QnXG59KVxuZXhwb3J0IGNsYXNzIEdycGNXZWJDbGllbnRGYWN0b3J5IGltcGxlbWVudHMgR3JwY0NsaWVudEZhY3Rvcnkge1xuXG4gIGNvbnN0cnVjdG9yKFxuICAgIEBPcHRpb25hbCgpIEBJbmplY3QoR1JQQ19XRUJfQ0xJRU5UX0RFRkFVTFRfU0VUVElOR1MpIHByaXZhdGUgZGVmYXVsdFNldHRpbmdzOiBHcnBjQ2xpZW50U2V0dGluZ3MsXG4gICkgeyB9XG5cbiAgY3JlYXRlQ2xpZW50KHNlcnZpY2VJZDogc3RyaW5nLCBjdXN0b21TZXR0aW5nczogR3JwY0NsaWVudFNldHRpbmdzKSB7XG4gICAgY29uc3Qgc2V0dGluZ3MgPSBjdXN0b21TZXR0aW5ncyB8fCB0aGlzLmRlZmF1bHRTZXR0aW5ncztcblxuICAgIGlmICghc2V0dGluZ3MpIHtcbiAgICAgIHRocm93IG5ldyBFcnJvcihgZ3JwYy13ZWIgY2xpZW50IGZhY3Rvcnk6IG5vIHNldHRpbmdzIHByb3ZpZGVkIGZvciAke3NlcnZpY2VJZH1gKTtcbiAgICB9XG5cbiAgICByZXR1cm4gbmV3IEdycGNXZWJDbGllbnQoeyAuLi5zZXR0aW5ncyB9KTtcbiAgfVxuXG59XG5cbi8qKlxuICogR3JwY0NsaWVudCBpbXBsZW1lbnRhdGlvbiBiYXNlZCBvbiBncnBjLXdlYlxuICovXG5leHBvcnQgY2xhc3MgR3JwY1dlYkNsaWVudCBpbXBsZW1lbnRzIEdycGNDbGllbnQge1xuXG4gIHByaXZhdGUgY2xpZW50OiBHcnBjV2ViQ2xpZW50QmFzZTtcblxuICBjb25zdHJ1Y3RvcihcbiAgICBwcml2YXRlIHNldHRpbmdzOiBHcnBjQ2xpZW50U2V0dGluZ3MsXG4gICkge1xuICAgIHRoaXMuY2xpZW50ID0gbmV3IEdycGNXZWJDbGllbnRCYXNlKHRoaXMuc2V0dGluZ3MpO1xuICB9XG5cbiAgdW5hcnk8USBleHRlbmRzIEdycGNNZXNzYWdlLCBTIGV4dGVuZHMgR3JwY01lc3NhZ2U+KFxuICAgIHBhdGg6IHN0cmluZyxcbiAgICByZXE6IFEsXG4gICAgbWV0YWRhdGE6IE1ldGFkYXRhLFxuICAgIHJlcWNsc3M6IEdycGNNZXNzYWdlQ2xhc3M8UT4sXG4gICAgcmVzY2xzczogR3JwY01lc3NhZ2VDbGFzczxTPixcbiAgKTogT2JzZXJ2YWJsZTxHcnBjRXZlbnQ8Uz4+IHtcbiAgICByZXR1cm4gbmV3IE9ic2VydmFibGUob2JzID0+IHtcbiAgICAgIGNvbnN0IHN0cmVhbSA9IHRoaXMuY2xpZW50LnJwY0NhbGwoXG4gICAgICAgIHRoaXMuc2V0dGluZ3MuaG9zdCArIHBhdGgsXG4gICAgICAgIHJlcSxcbiAgICAgICAgbWV0YWRhdGEgfHwge30sXG4gICAgICAgIG5ldyBBYnN0cmFjdENsaWVudEJhc2UuTWV0aG9kSW5mbyhcbiAgICAgICAgICByZXNjbHNzLFxuICAgICAgICAgIChyZXF1ZXN0OiBRKSA9PiByZXF1ZXN0LnNlcmlhbGl6ZUJpbmFyeSgpLFxuICAgICAgICAgIHJlc2Nsc3MuZGVzZXJpYWxpemVCaW5hcnlcbiAgICAgICAgKSxcbiAgICAgICAgKGVycm9yLCBkYXRhKSA9PiB7XG4gICAgICAgICAgaWYgKGVycm9yKSB7XG4gICAgICAgICAgICBvYnMubmV4dChuZXcgR3JwY1N0YXR1c0V2ZW50KGVycm9yLmNvZGUsIGVycm9yLm1lc3NhZ2UsIChlcnJvciBhcyBhbnkpLm1ldGFkYXRhKSk7XG4gICAgICAgICAgICBvYnMuY29tcGxldGUoKTtcbiAgICAgICAgICB9IGVsc2Uge1xuICAgICAgICAgICAgb2JzLm5leHQobmV3IEdycGNEYXRhRXZlbnQoZGF0YSkpO1xuICAgICAgICAgIH1cbiAgICAgICAgfVxuICAgICAgKTtcblxuICAgICAgLy8gdGFrZSBvbmx5IHN0YXR1cyAwIGJlY2F1c2UgdW5hcnkgZXJyb3IgYWxyZWFkeSBpbmNsdWRlcyBub24temVybyBzdGF0dXNlc1xuICAgICAgc3RyZWFtLm9uKCdzdGF0dXMnLCBzdGF0dXMgPT4gc3RhdHVzLmNvZGUgPT09IDAgPyBvYnMubmV4dChuZXcgR3JwY1N0YXR1c0V2ZW50KHN0YXR1cy5jb2RlLCBzdGF0dXMuZGV0YWlscywgc3RhdHVzLm1ldGFkYXRhKSkgOiBudWxsKTtcbiAgICAgIHN0cmVhbS5vbignZW5kJywgKCkgPT4gb2JzLmNvbXBsZXRlKCkpO1xuXG4gICAgICByZXR1cm4gKCkgPT4gc3RyZWFtLmNhbmNlbCgpO1xuICAgIH0pO1xuICB9XG5cbiAgc2VydmVyU3RyZWFtPFEgZXh0ZW5kcyBHcnBjTWVzc2FnZSwgUyBleHRlbmRzIEdycGNNZXNzYWdlPihcbiAgICBwYXRoOiBzdHJpbmcsXG4gICAgcmVxOiBRLFxuICAgIG1ldGFkYXRhOiBNZXRhZGF0YSxcbiAgICByZXFjbHNzOiBHcnBjTWVzc2FnZUNsYXNzPFE+LFxuICAgIHJlc2Nsc3M6IEdycGNNZXNzYWdlQ2xhc3M8Uz5cbiAgKTogT2JzZXJ2YWJsZTxHcnBjRXZlbnQ8Uz4+IHtcbiAgICByZXR1cm4gbmV3IE9ic2VydmFibGUob2JzID0+IHtcbiAgICAgIGNvbnN0IHN0cmVhbSA9IHRoaXMuY2xpZW50LnNlcnZlclN0cmVhbWluZyhcbiAgICAgICAgdGhpcy5zZXR0aW5ncy5ob3N0ICsgcGF0aCxcbiAgICAgICAgcmVxLFxuICAgICAgICBtZXRhZGF0YSB8fCB7fSxcbiAgICAgICAgbmV3IEFic3RyYWN0Q2xpZW50QmFzZS5NZXRob2RJbmZvKHJlc2Nsc3MsIChyZXF1ZXN0OiBRKSA9PiByZXF1ZXN0LnNlcmlhbGl6ZUJpbmFyeSgpLCByZXNjbHNzLmRlc2VyaWFsaXplQmluYXJ5KVxuICAgICAgKTtcblxuICAgICAgc3RyZWFtLm9uKCdzdGF0dXMnLCBzdGF0dXMgPT4gb2JzLm5leHQobmV3IEdycGNTdGF0dXNFdmVudChzdGF0dXMuY29kZSwgc3RhdHVzLmRldGFpbHMsIHN0YXR1cy5tZXRhZGF0YSkpKTtcbiAgICAgIHN0cmVhbS5vbignZXJyb3InLCBlcnJvciA9PiB7XG4gICAgICAgIG9icy5uZXh0KG5ldyBHcnBjU3RhdHVzRXZlbnQoZXJyb3IuY29kZSwgZXJyb3IubWVzc2FnZSwgKGVycm9yIGFzIGFueSkubWV0YWRhdGEpKTtcbiAgICAgICAgb2JzLmNvbXBsZXRlKCk7XG4gICAgICB9KTtcbiAgICAgIHN0cmVhbS5vbignZGF0YScsIGRhdGEgPT4gb2JzLm5leHQobmV3IEdycGNEYXRhRXZlbnQoZGF0YSkpKTtcbiAgICAgIHN0cmVhbS5vbignZW5kJywgKCkgPT4gb2JzLmNvbXBsZXRlKCkpO1xuXG4gICAgICByZXR1cm4gKCkgPT4gc3RyZWFtLmNhbmNlbCgpO1xuICAgIH0pO1xuICB9XG5cbn1cbiJdfQ== |
import { InjectionToken } from '@angular/core'; | ||
/** | ||
* Default configuration for grpc-web clients. Will be used for every GrpcWebClient unless service-specific config is provided | ||
* | ||
* Example: | ||
* | ||
* ``` | ||
* providers: [ | ||
* { provide: GRPC_WEB_CLIENT_DEFAULT_SETTINGS, useClass: { host: 'localhost:4321' } }, | ||
* ] | ||
* ``` | ||
*/ | ||
export const GRPC_WEB_CLIENT_DEFAULT_SETTINGS = new InjectionToken('GRPC_WEB_CLIENT_DEFAULT_SETTINGS'); | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidG9rZW5zLmpzIiwic291cmNlUm9vdCI6Im5nOi8vQG5neC1ncnBjL2dycGMtd2ViLWNsaWVudC8iLCJzb3VyY2VzIjpbImxpYi90b2tlbnMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBQUEsT0FBTyxFQUFFLGNBQWMsRUFBRSxNQUFNLGVBQWUsQ0FBQztBQUUvQyxNQUFNLENBQUMsTUFBTSxnQ0FBZ0MsR0FBRyxJQUFJLGNBQWMsQ0FBQyxrQ0FBa0MsQ0FBQyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSW5qZWN0aW9uVG9rZW4gfSBmcm9tICdAYW5ndWxhci9jb3JlJztcblxuZXhwb3J0IGNvbnN0IEdSUENfV0VCX0NMSUVOVF9ERUZBVUxUX1NFVFRJTkdTID0gbmV3IEluamVjdGlvblRva2VuKCdHUlBDX1dFQl9DTElFTlRfREVGQVVMVF9TRVRUSU5HUycpO1xuIl19 | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidG9rZW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vcGFja2FnZXMvZ3JwYy13ZWItY2xpZW50L3NyYy9saWIvdG9rZW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE9BQU8sRUFBRSxjQUFjLEVBQUUsTUFBTSxlQUFlLENBQUM7QUFFL0M7Ozs7Ozs7Ozs7R0FVRztBQUNILE1BQU0sQ0FBQyxNQUFNLGdDQUFnQyxHQUFHLElBQUksY0FBYyxDQUFDLGtDQUFrQyxDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBJbmplY3Rpb25Ub2tlbiB9IGZyb20gJ0Bhbmd1bGFyL2NvcmUnO1xuXG4vKipcbiAqIERlZmF1bHQgY29uZmlndXJhdGlvbiBmb3IgZ3JwYy13ZWIgY2xpZW50cy4gV2lsbCBiZSB1c2VkIGZvciBldmVyeSBHcnBjV2ViQ2xpZW50IHVubGVzcyBzZXJ2aWNlLXNwZWNpZmljIGNvbmZpZyBpcyBwcm92aWRlZFxuICpcbiAqIEV4YW1wbGU6XG4gKlxuICogYGBgXG4gKiBwcm92aWRlcnM6IFtcbiAqICAgeyBwcm92aWRlOiBHUlBDX1dFQl9DTElFTlRfREVGQVVMVF9TRVRUSU5HUywgdXNlQ2xhc3M6IHsgaG9zdDogJ2xvY2FsaG9zdDo0MzIxJyB9IH0sXG4gKiBdXG4gKiBgYGBcbiAqL1xuZXhwb3J0IGNvbnN0IEdSUENfV0VCX0NMSUVOVF9ERUZBVUxUX1NFVFRJTkdTID0gbmV3IEluamVjdGlvblRva2VuKCdHUlBDX1dFQl9DTElFTlRfREVGQVVMVF9TRVRUSU5HUycpO1xuIl19 |
@@ -5,2 +5,2 @@ /** | ||
export * from './public-api'; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibmd4LWdycGMtZ3JwYy13ZWItY2xpZW50LmpzIiwic291cmNlUm9vdCI6Im5nOi8vQG5neC1ncnBjL2dycGMtd2ViLWNsaWVudC8iLCJzb3VyY2VzIjpbIm5neC1ncnBjLWdycGMtd2ViLWNsaWVudC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQTs7R0FFRztBQUVILGNBQWMsY0FBYyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiLyoqXG4gKiBHZW5lcmF0ZWQgYnVuZGxlIGluZGV4LiBEbyBub3QgZWRpdC5cbiAqL1xuXG5leHBvcnQgKiBmcm9tICcuL3B1YmxpYy1hcGknO1xuIl19 | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibmd4LWdycGMtZ3JwYy13ZWItY2xpZW50LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vcGFja2FnZXMvZ3JwYy13ZWItY2xpZW50L3NyYy9uZ3gtZ3JwYy1ncnBjLXdlYi1jbGllbnQudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBQUE7O0dBRUc7QUFFSCxjQUFjLGNBQWMsQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbIi8qKlxuICogR2VuZXJhdGVkIGJ1bmRsZSBpbmRleC4gRG8gbm90IGVkaXQuXG4gKi9cblxuZXhwb3J0ICogZnJvbSAnLi9wdWJsaWMtYXBpJztcbiJdfQ== |
export * from './lib/grpc-web-client'; | ||
export * from './lib/tokens'; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicHVibGljLWFwaS5qcyIsInNvdXJjZVJvb3QiOiJuZzovL0BuZ3gtZ3JwYy9ncnBjLXdlYi1jbGllbnQvIiwic291cmNlcyI6WyJwdWJsaWMtYXBpLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLGNBQWMsdUJBQXVCLENBQUM7QUFDdEMsY0FBYyxjQUFjLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJleHBvcnQgKiBmcm9tICcuL2xpYi9ncnBjLXdlYi1jbGllbnQnO1xuZXhwb3J0ICogZnJvbSAnLi9saWIvdG9rZW5zJztcblxuIl19 | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicHVibGljLWFwaS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uL3BhY2thZ2VzL2dycGMtd2ViLWNsaWVudC9zcmMvcHVibGljLWFwaS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxjQUFjLHVCQUF1QixDQUFDO0FBQ3RDLGNBQWMsY0FBYyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiZXhwb3J0ICogZnJvbSAnLi9saWIvZ3JwYy13ZWItY2xpZW50JztcbmV4cG9ydCAqIGZyb20gJy4vbGliL3Rva2Vucyc7XG5cbiJdfQ== |
@@ -1,3 +0,2 @@ | ||
import { __decorate, __param } from 'tslib'; | ||
import { InjectionToken, Optional, Inject, ɵɵdefineInjectable, ɵɵinject, Injectable } from '@angular/core'; | ||
import { InjectionToken, ɵɵdefineInjectable, ɵɵinject, Injectable, Optional, Inject } from '@angular/core'; | ||
import { GrpcStatusEvent, GrpcDataEvent } from '@ngx-grpc/common'; | ||
@@ -7,5 +6,19 @@ import { GrpcWebClientBase, AbstractClientBase } from 'grpc-web'; | ||
/** | ||
* Default configuration for grpc-web clients. Will be used for every GrpcWebClient unless service-specific config is provided | ||
* | ||
* Example: | ||
* | ||
* ``` | ||
* providers: [ | ||
* { provide: GRPC_WEB_CLIENT_DEFAULT_SETTINGS, useClass: { host: 'localhost:4321' } }, | ||
* ] | ||
* ``` | ||
*/ | ||
const GRPC_WEB_CLIENT_DEFAULT_SETTINGS = new InjectionToken('GRPC_WEB_CLIENT_DEFAULT_SETTINGS'); | ||
let GrpcWebClientFactory = class GrpcWebClientFactory { | ||
/** | ||
* GrpcClientFactory implementation based on grpc-web | ||
*/ | ||
class GrpcWebClientFactory { | ||
constructor(defaultSettings) { | ||
@@ -21,13 +34,15 @@ this.defaultSettings = defaultSettings; | ||
} | ||
}; | ||
} | ||
GrpcWebClientFactory.ɵprov = ɵɵdefineInjectable({ factory: function GrpcWebClientFactory_Factory() { return new GrpcWebClientFactory(ɵɵinject(GRPC_WEB_CLIENT_DEFAULT_SETTINGS, 8)); }, token: GrpcWebClientFactory, providedIn: "root" }); | ||
GrpcWebClientFactory.decorators = [ | ||
{ type: Injectable, args: [{ | ||
providedIn: 'root' | ||
},] } | ||
]; | ||
GrpcWebClientFactory.ctorParameters = () => [ | ||
{ type: undefined, decorators: [{ type: Optional }, { type: Inject, args: [GRPC_WEB_CLIENT_DEFAULT_SETTINGS,] }] } | ||
]; | ||
GrpcWebClientFactory.ɵprov = ɵɵdefineInjectable({ factory: function GrpcWebClientFactory_Factory() { return new GrpcWebClientFactory(ɵɵinject(GRPC_WEB_CLIENT_DEFAULT_SETTINGS, 8)); }, token: GrpcWebClientFactory, providedIn: "root" }); | ||
GrpcWebClientFactory = __decorate([ | ||
Injectable({ | ||
providedIn: 'root' | ||
}), | ||
__param(0, Optional()), __param(0, Inject(GRPC_WEB_CLIENT_DEFAULT_SETTINGS)) | ||
], GrpcWebClientFactory); | ||
/** | ||
* GrpcClient implementation based on grpc-web | ||
*/ | ||
class GrpcWebClient { | ||
@@ -40,3 +55,3 @@ constructor(settings) { | ||
return new Observable(obs => { | ||
const stream = this.client.rpcCall(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => reqclss.toBinary(request), resclss.fromBinary), (error, data) => { | ||
const stream = this.client.rpcCall(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => request.serializeBinary(), resclss.deserializeBinary), (error, data) => { | ||
if (error) { | ||
@@ -58,3 +73,3 @@ obs.next(new GrpcStatusEvent(error.code, error.message, error.metadata)); | ||
return new Observable(obs => { | ||
const stream = this.client.serverStreaming(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => reqclss.toBinary(request), resclss.fromBinary)); | ||
const stream = this.client.serverStreaming(this.settings.host + path, req, metadata || {}, new AbstractClientBase.MethodInfo(resclss, (request) => request.serializeBinary(), resclss.deserializeBinary)); | ||
stream.on('status', status => obs.next(new GrpcStatusEvent(status.code, status.details, status.metadata))); | ||
@@ -61,0 +76,0 @@ stream.on('error', error => { |
import { GrpcClient, GrpcClientFactory, GrpcClientSettings, GrpcEvent, GrpcMessage, GrpcMessageClass } from '@ngx-grpc/common'; | ||
import { Metadata } from 'grpc-web'; | ||
import { Observable } from 'rxjs'; | ||
/** | ||
* GrpcClientFactory implementation based on grpc-web | ||
*/ | ||
export declare class GrpcWebClientFactory implements GrpcClientFactory { | ||
@@ -9,2 +12,5 @@ private defaultSettings; | ||
} | ||
/** | ||
* GrpcClient implementation based on grpc-web | ||
*/ | ||
export declare class GrpcWebClient implements GrpcClient { | ||
@@ -11,0 +17,0 @@ private settings; |
import { InjectionToken } from '@angular/core'; | ||
/** | ||
* Default configuration for grpc-web clients. Will be used for every GrpcWebClient unless service-specific config is provided | ||
* | ||
* Example: | ||
* | ||
* ``` | ||
* providers: [ | ||
* { provide: GRPC_WEB_CLIENT_DEFAULT_SETTINGS, useClass: { host: 'localhost:4321' } }, | ||
* ] | ||
* ``` | ||
*/ | ||
export declare const GRPC_WEB_CLIENT_DEFAULT_SETTINGS: InjectionToken<unknown>; |
@@ -1,1 +0,1 @@ | ||
{"__symbolic":"module","version":4,"metadata":{"GrpcWebClientFactory":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":6,"character":1},"arguments":[{"providedIn":"root"}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":12,"character":5}},{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":12,"character":17},"arguments":[{"__symbolic":"reference","name":"GRPC_WEB_CLIENT_DEFAULT_SETTINGS"}]}]],"parameters":[{"__symbolic":"reference","module":"@ngx-grpc/common","name":"GrpcClientSettings","line":12,"character":83}]}],"createClient":[{"__symbolic":"method"}]},"statics":{"ɵprov":{}}},"GrpcWebClient":{"__symbolic":"class","members":{"__ctor__":[{"__symbolic":"constructor","parameters":[{"__symbolic":"reference","module":"@ngx-grpc/common","name":"GrpcClientSettings","line":12,"character":83}]}],"unary":[{"__symbolic":"method"}],"serverStream":[{"__symbolic":"method"}]}},"GRPC_WEB_CLIENT_DEFAULT_SETTINGS":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":2,"character":52},"arguments":["GRPC_WEB_CLIENT_DEFAULT_SETTINGS"]}},"origins":{"GrpcWebClientFactory":"./lib/grpc-web-client","GrpcWebClient":"./lib/grpc-web-client","GRPC_WEB_CLIENT_DEFAULT_SETTINGS":"./lib/tokens"},"importAs":"@ngx-grpc/grpc-web-client"} | ||
{"__symbolic":"module","version":4,"metadata":{"GrpcWebClientFactory":{"__symbolic":"class","decorators":[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Injectable","line":9,"character":1},"arguments":[{"providedIn":"root"}]}],"members":{"__ctor__":[{"__symbolic":"constructor","parameterDecorators":[[{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Optional","line":15,"character":5}},{"__symbolic":"call","expression":{"__symbolic":"reference","module":"@angular/core","name":"Inject","line":15,"character":17},"arguments":[{"__symbolic":"reference","name":"GRPC_WEB_CLIENT_DEFAULT_SETTINGS"}]}]],"parameters":[{"__symbolic":"reference","module":"@ngx-grpc/common","name":"GrpcClientSettings","line":15,"character":83}]}],"createClient":[{"__symbolic":"method"}]},"statics":{"ɵprov":{}}},"GrpcWebClient":{"__symbolic":"class","members":{"__ctor__":[{"__symbolic":"constructor","parameters":[{"__symbolic":"reference","module":"@ngx-grpc/common","name":"GrpcClientSettings","line":15,"character":83}]}],"unary":[{"__symbolic":"method"}],"serverStream":[{"__symbolic":"method"}]}},"GRPC_WEB_CLIENT_DEFAULT_SETTINGS":{"__symbolic":"new","expression":{"__symbolic":"reference","module":"@angular/core","name":"InjectionToken","line":13,"character":52},"arguments":["GRPC_WEB_CLIENT_DEFAULT_SETTINGS"]}},"origins":{"GrpcWebClientFactory":"./lib/grpc-web-client","GrpcWebClient":"./lib/grpc-web-client","GRPC_WEB_CLIENT_DEFAULT_SETTINGS":"./lib/tokens"},"importAs":"@ngx-grpc/grpc-web-client"} |
{ | ||
"name": "@ngx-grpc/grpc-web-client", | ||
"peerDependencies": { | ||
"@ngx-grpc/common": "0.4.3", | ||
"@angular/core": "^9.0.1", | ||
"grpc-web": "^1.2.0", | ||
"tslib": "^1.10.0" | ||
"@ngx-grpc/common": "1.0.0", | ||
"@angular/core": ">=8.0.0", | ||
"grpc-web": "^1.2.0" | ||
}, | ||
"dependencies": { | ||
"tslib": "^2.0.0" | ||
}, | ||
"main": "bundles/ngx-grpc-grpc-web-client.umd.js", | ||
"module": "fesm5/ngx-grpc-grpc-web-client.js", | ||
"module": "fesm2015/ngx-grpc-grpc-web-client.js", | ||
"es2015": "fesm2015/ngx-grpc-grpc-web-client.js", | ||
"esm5": "esm5/ngx-grpc-grpc-web-client.js", | ||
"esm2015": "esm2015/ngx-grpc-grpc-web-client.js", | ||
"fesm5": "fesm5/ngx-grpc-grpc-web-client.js", | ||
"fesm2015": "fesm2015/ngx-grpc-grpc-web-client.js", | ||
@@ -19,3 +19,3 @@ "typings": "ngx-grpc-grpc-web-client.d.ts", | ||
"sideEffects": false, | ||
"version": "0.4.3" | ||
"version": "1.0.0" | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Mixed license
License(Experimental) Package contains multiple licenses.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
0
2
51298
18
316
1
+ Addedtslib@^2.0.0
+ Added@angular/core@18.2.5(transitive)
+ Added@ngx-grpc/common@1.0.0(transitive)
+ Addedrxjs@7.8.1(transitive)
+ Addedtslib@2.7.0(transitive)
+ Addedzone.js@0.14.10(transitive)
- Removed@angular/core@9.1.13(transitive)
- Removed@ngx-grpc/common@0.4.3(transitive)
- Removedzone.js@0.10.3(transitive)