@cheep/transport
Advanced tools
Comparing version 1.0.0-beta.5 to 1.0.0-beta.6
{ | ||
"name": "@cheep/transport", | ||
"version": "1.0.0-beta.5", | ||
"version": "1.0.0-beta.6", | ||
"main": "src/index.js", | ||
"typings": "src/index.d.ts", | ||
"dependencies": { | ||
"reflect-metadata": "^0.1.13" | ||
}, | ||
"peerDependencies": {} | ||
"typings": "src/index.d.ts" | ||
} |
@@ -1,2 +0,1 @@ | ||
import 'reflect-metadata'; | ||
import { ExecuteProps, FireAndForgetHandler, MessageMetadata, MetadataReducer, MetadataValidator, PublishProps, RouteHandler, Transport, TransportMessage, TransportState } from './transport'; | ||
@@ -3,0 +2,0 @@ export interface TransportOptions<TMeta extends MessageMetadata = MessageMetadata> { |
@@ -5,3 +5,2 @@ "use strict"; | ||
const tslib_1 = require("tslib"); | ||
require("reflect-metadata"); | ||
const remote_error_1 = require("./remote.error"); | ||
@@ -167,3 +166,5 @@ const rpcTimeout_error_1 = require("./rpcTimeout.error"); | ||
// start processing message | ||
const message = this.utils.jsonDecode(msg.message); | ||
const message = msg.message | ||
? this.utils.jsonDecode(msg.message) | ||
: msg.message; | ||
const registeredPrefixes = [ | ||
@@ -170,0 +171,0 @@ ...this.registeredPrefixes, |
Sorry, the diff of this file is not supported yet
0
48339
- Removedreflect-metadata@^0.1.13
- Removedreflect-metadata@0.1.14(transitive)