@protobuf-ts/twirp-transport
Advanced tools
Comparing version 2.1.0 to 2.2.0-alpha.0
@@ -65,2 +65,4 @@ "use strict"; | ||
: new runtime_rpc_1.RpcError(reason instanceof Error ? reason.message : reason, twitch_twirp_error_code_1.TwirpErrorCode[twitch_twirp_error_code_1.TwirpErrorCode.internal]); | ||
error.methodName = method.name; | ||
error.serviceName = method.service.typeName; | ||
defHeader.rejectPending(error); | ||
@@ -101,12 +103,21 @@ defMessage.rejectPending(error); | ||
} | ||
clientStreaming( /*service: ServiceInfo, method: MethodInfo<I, O>, options: RpcOptions*/) { | ||
throw new runtime_rpc_1.RpcError('Client streaming is not supported by Twirp', twitch_twirp_error_code_1.TwirpErrorCode[twitch_twirp_error_code_1.TwirpErrorCode.unimplemented]); | ||
clientStreaming(method /*, options: RpcOptions*/) { | ||
const e = new runtime_rpc_1.RpcError('Client streaming is not supported by Twirp', twitch_twirp_error_code_1.TwirpErrorCode[twitch_twirp_error_code_1.TwirpErrorCode.unimplemented]); | ||
e.methodName = method.name; | ||
e.serviceName = method.service.typeName; | ||
throw e; | ||
} | ||
duplex( /*service: ServiceInfo, method: MethodInfo<I, O>, options: RpcOptions*/) { | ||
throw new runtime_rpc_1.RpcError('Duplex streaming is not supported by Twirp', twitch_twirp_error_code_1.TwirpErrorCode[twitch_twirp_error_code_1.TwirpErrorCode.unimplemented]); | ||
duplex(method /*, options: RpcOptions*/) { | ||
const e = new runtime_rpc_1.RpcError('Duplex streaming is not supported by Twirp', twitch_twirp_error_code_1.TwirpErrorCode[twitch_twirp_error_code_1.TwirpErrorCode.unimplemented]); | ||
e.methodName = method.name; | ||
e.serviceName = method.service.typeName; | ||
throw e; | ||
} | ||
serverStreaming( /*service: ServiceInfo, method: MethodInfo<I, O>, input: I, options?: RpcOptions*/) { | ||
throw new runtime_rpc_1.RpcError('Server streaming is not supported by Twirp', twitch_twirp_error_code_1.TwirpErrorCode[twitch_twirp_error_code_1.TwirpErrorCode.unimplemented]); | ||
serverStreaming(method /*, input: I, options?: RpcOptions*/) { | ||
const e = new runtime_rpc_1.RpcError('Server streaming is not supported by Twirp', twitch_twirp_error_code_1.TwirpErrorCode[twitch_twirp_error_code_1.TwirpErrorCode.unimplemented]); | ||
e.methodName = method.name; | ||
e.serviceName = method.service.typeName; | ||
throw e; | ||
} | ||
} | ||
exports.TwirpFetchTransport = TwirpFetchTransport; |
@@ -62,2 +62,4 @@ import { createTwirpRequestHeader, parseMetadataFromResponseHeaders, parseTwirpErrorResponse } from "./twirp-format"; | ||
: new RpcError(reason instanceof Error ? reason.message : reason, TwirpErrorCode[TwirpErrorCode.internal]); | ||
error.methodName = method.name; | ||
error.serviceName = method.service.typeName; | ||
defHeader.rejectPending(error); | ||
@@ -98,11 +100,20 @@ defMessage.rejectPending(error); | ||
} | ||
clientStreaming( /*service: ServiceInfo, method: MethodInfo<I, O>, options: RpcOptions*/) { | ||
throw new RpcError('Client streaming is not supported by Twirp', TwirpErrorCode[TwirpErrorCode.unimplemented]); | ||
clientStreaming(method /*, options: RpcOptions*/) { | ||
const e = new RpcError('Client streaming is not supported by Twirp', TwirpErrorCode[TwirpErrorCode.unimplemented]); | ||
e.methodName = method.name; | ||
e.serviceName = method.service.typeName; | ||
throw e; | ||
} | ||
duplex( /*service: ServiceInfo, method: MethodInfo<I, O>, options: RpcOptions*/) { | ||
throw new RpcError('Duplex streaming is not supported by Twirp', TwirpErrorCode[TwirpErrorCode.unimplemented]); | ||
duplex(method /*, options: RpcOptions*/) { | ||
const e = new RpcError('Duplex streaming is not supported by Twirp', TwirpErrorCode[TwirpErrorCode.unimplemented]); | ||
e.methodName = method.name; | ||
e.serviceName = method.service.typeName; | ||
throw e; | ||
} | ||
serverStreaming( /*service: ServiceInfo, method: MethodInfo<I, O>, input: I, options?: RpcOptions*/) { | ||
throw new RpcError('Server streaming is not supported by Twirp', TwirpErrorCode[TwirpErrorCode.unimplemented]); | ||
serverStreaming(method /*, input: I, options?: RpcOptions*/) { | ||
const e = new RpcError('Server streaming is not supported by Twirp', TwirpErrorCode[TwirpErrorCode.unimplemented]); | ||
e.methodName = method.name; | ||
e.serviceName = method.service.typeName; | ||
throw e; | ||
} | ||
} |
@@ -32,5 +32,5 @@ import { TwirpOptions } from "./twirp-options"; | ||
protected makeUrl(method: MethodInfo, options: TwirpOptions): string; | ||
clientStreaming<I extends object, O extends object>(): ClientStreamingCall<I, O>; | ||
duplex<I extends object, O extends object>(): DuplexStreamingCall<I, O>; | ||
serverStreaming<I extends object, O extends object>(): ServerStreamingCall<I, O>; | ||
clientStreaming<I extends object, O extends object>(method: MethodInfo<I, O>): ClientStreamingCall<I, O>; | ||
duplex<I extends object, O extends object>(method: MethodInfo<I, O>): DuplexStreamingCall<I, O>; | ||
serverStreaming<I extends object, O extends object>(method: MethodInfo<I, O>): ServerStreamingCall<I, O>; | ||
} |
{ | ||
"name": "@protobuf-ts/twirp-transport", | ||
"version": "2.1.0", | ||
"version": "2.2.0-alpha.0", | ||
"description": "Twirp transport for clients generated by the protoc plugin \"protobuf-ts\".", | ||
@@ -42,6 +42,6 @@ "license": "Apache-2.0", | ||
"dependencies": { | ||
"@protobuf-ts/runtime": "^2.1.0", | ||
"@protobuf-ts/runtime-rpc": "^2.1.0" | ||
"@protobuf-ts/runtime": "^2.2.0-alpha.0", | ||
"@protobuf-ts/runtime-rpc": "^2.2.0-alpha.0" | ||
}, | ||
"gitHead": "bc8be3ac6a109d66d3c602b1309e136980933c1d" | ||
"gitHead": "a5f300a2bcaad58fe20b91952e12bc78743b1153" | ||
} |
Sorry, the diff of this file is not supported yet
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
833
186865
1