Socket
Socket
Sign inDemoInstall

@ngx-grpc/grpc-web-client

Package Overview
Dependencies
Maintainers
1
Versions
26
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@ngx-grpc/grpc-web-client - npm Package Compare versions

Comparing version 0.4.3 to 1.0.0

247

bundles/ngx-grpc-grpc-web-client.umd.js

@@ -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

31

esm2015/lib/grpc-web-client.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc