@pbkit/runtime - npm Package Compare versions

Comparing version 0.0.22 to 0.0.23

async/observer.js

		@@ -37,3 +37,3 @@ "use strict";
		observer.complete();
		array_1.removeItem(observers, observer);
		(0, array_1.removeItem)(observers, observer);
		};
		@@ -40,0 +40,0 @@ };

package.json

		{
		"name": "@pbkit/runtime",
		"version": "0.0.22",
		"version": "0.0.23",
		"author": "JongChan Choi <jong@chan.moe>",
		@@ -5,0 +5,0 @@ "license": "(MIT OR Apache-2.0)",

rpc.js

		@@ -8,6 +8,6 @@ "use strict";
		return (messages, metadata) => {
		const headerPromise = observer_1.defer();
		const trailerPromise = observer_1.defer();
		const drainEnd = observer_1.defer();
		const eventBuffer = event_buffer_1.createEventBuffer({
		const headerPromise = (0, observer_1.defer)();
		const trailerPromise = (0, observer_1.defer)();
		const drainEnd = (0, observer_1.defer)();
		const eventBuffer = (0, event_buffer_1.createEventBuffer)({
		onDrainEnd: drainEnd.resolve,
		@@ -27,3 +27,3 @@ });
		function createServerImplBuilder() {
		const buffer = event_buffer_1.createEventBuffer();
		const buffer = (0, event_buffer_1.createEventBuffer)();
		return {
		@@ -30,0 +30,0 @@ register(methodDescriptor, handler) {

wire/deserialize.js

		@@ -12,3 +12,3 @@ "use strict";
		while (idx < uint8array.length) {
		const decodeResult = varint_1.decode(new DataView(uint8array.buffer, offset + idx));
		const decodeResult = (0, varint_1.decode)(new DataView(uint8array.buffer, offset + idx));
		const key = decodeResult[1][0];
		@@ -20,3 +20,3 @@ idx += decodeResult[0];
		case index_1.WireType.Varint: {
		const [len, value] = varint_1.decode(new DataView(uint8array.buffer, offset + idx));
		const [len, value] = (0, varint_1.decode)(new DataView(uint8array.buffer, offset + idx));
		result.push([fieldNumber, { type, value }]);
		@@ -36,3 +36,3 @@ idx += len;
		case index_1.WireType.LengthDelimited: {
		const [len, value] = varint_1.decode(new DataView(uint8array.buffer, offset + idx));
		const [len, value] = (0, varint_1.decode)(new DataView(uint8array.buffer, offset + idx));
		result.push([fieldNumber, {
		@@ -39,0 +39,0 @@ type,

wire/scalar.js

		@@ -14,4 +14,4 @@ "use strict";
		uint64: (long) => long.toString(false),
		sint32: (long) => zigzag_1.decode(long[0]),
		sint64: (long) => zigzag_1.decode(long).toString(true),
		sint32: (long) => (0, zigzag_1.decode)(long[0]),
		sint64: (long) => (0, zigzag_1.decode)(long).toString(true),
		bool: (long) => long[0] !== 0,
		@@ -24,4 +24,4 @@ };
		uint64: (tsValue) => Long_1.default.parse(tsValue),
		sint32: (tsValue) => zigzag_1.encode(new Long_1.default(tsValue)),
		sint64: (tsValue) => zigzag_1.encode(Long_1.default.parse(tsValue)),
		sint32: (tsValue) => (0, zigzag_1.encode)(new Long_1.default(tsValue)),
		sint64: (tsValue) => (0, zigzag_1.encode)(Long_1.default.parse(tsValue)),
		bool: (tsValue) => new Long_1.default(+tsValue),
		@@ -208,5 +208,5 @@ };
		type: index_1.WireType.LengthDelimited,
		value: serialize_1.concat(tsValues.map((tsValue) => {
		value: (0, serialize_1.concat)(tsValues.map((tsValue) => {
		const value = encodeVarintFns[type](tsValue);
		return varint_1.encode(value);
		return (0, varint_1.encode)(value);
		})),
		@@ -282,3 +282,3 @@ };
		while (idx < value.length) {
		const decodeResult = varint_1.decode(new DataView(value.buffer, offset + idx));
		const decodeResult = (0, varint_1.decode)(new DataView(value.buffer, offset + idx));
		idx += decodeResult[0];
		@@ -285,0 +285,0 @@ yield decodeResult[1];

wire/serialize.js

		@@ -9,6 +9,6 @@ "use strict";
		wireMessage.forEach(([fieldNumber, field]) => {
		result.push(varint_1.encode((fieldNumber << 3) \| field.type));
		result.push((0, varint_1.encode)((fieldNumber << 3) \| field.type));
		switch (field.type) {
		case index_1.WireType.Varint:
		result.push(varint_1.encode(field.value));
		result.push((0, varint_1.encode)(field.value));
		break;
		@@ -24,3 +24,3 @@ case index_1.WireType.Fixed64: {
		case index_1.WireType.LengthDelimited:
		result.push(varint_1.encode(field.value.byteLength));
		result.push((0, varint_1.encode)(field.value.byteLength));
		result.push(field.value);
		@@ -27,0 +27,0 @@ break;

New alerts