mirror of
https://github.com/mountain-loop/yaak.git
synced 2026-07-07 05:15:20 +02:00
Re-gen proto stuff
This commit is contained in:
@@ -1,12 +1,12 @@
|
|||||||
// Code generated by protoc-gen-ts_proto. DO NOT EDIT.
|
// Code generated by protoc-gen-ts_proto. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-ts_proto v1.180.0
|
// protoc-gen-ts_proto v2.2.0
|
||||||
// protoc v3.19.1
|
// protoc v3.19.1
|
||||||
// source: plugins/runtime.proto
|
// source: plugins/runtime.proto
|
||||||
|
|
||||||
/* eslint-disable */
|
/* eslint-disable */
|
||||||
|
import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";
|
||||||
import { type CallContext, type CallOptions } from "nice-grpc-common";
|
import { type CallContext, type CallOptions } from "nice-grpc-common";
|
||||||
import * as _m0 from "protobufjs/minimal";
|
|
||||||
|
|
||||||
export const protobufPackage = "yaak.plugins.runtime";
|
export const protobufPackage = "yaak.plugins.runtime";
|
||||||
|
|
||||||
@@ -18,16 +18,16 @@ function createBaseEventStreamEvent(): EventStreamEvent {
|
|||||||
return { event: "" };
|
return { event: "" };
|
||||||
}
|
}
|
||||||
|
|
||||||
export const EventStreamEvent = {
|
export const EventStreamEvent: MessageFns<EventStreamEvent> = {
|
||||||
encode(message: EventStreamEvent, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
|
encode(message: EventStreamEvent, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
|
||||||
if (message.event !== "") {
|
if (message.event !== "") {
|
||||||
writer.uint32(10).string(message.event);
|
writer.uint32(10).string(message.event);
|
||||||
}
|
}
|
||||||
return writer;
|
return writer;
|
||||||
},
|
},
|
||||||
|
|
||||||
decode(input: _m0.Reader | Uint8Array, length?: number): EventStreamEvent {
|
decode(input: BinaryReader | Uint8Array, length?: number): EventStreamEvent {
|
||||||
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
|
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
|
||||||
let end = length === undefined ? reader.len : reader.pos + length;
|
let end = length === undefined ? reader.len : reader.pos + length;
|
||||||
const message = createBaseEventStreamEvent();
|
const message = createBaseEventStreamEvent();
|
||||||
while (reader.pos < end) {
|
while (reader.pos < end) {
|
||||||
@@ -44,7 +44,7 @@ export const EventStreamEvent = {
|
|||||||
if ((tag & 7) === 4 || tag === 0) {
|
if ((tag & 7) === 4 || tag === 0) {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
reader.skipType(tag & 7);
|
reader.skip(tag & 7);
|
||||||
}
|
}
|
||||||
return message;
|
return message;
|
||||||
},
|
},
|
||||||
@@ -114,3 +114,12 @@ function isSet(value: any): boolean {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export type ServerStreamingMethodResult<Response> = { [Symbol.asyncIterator](): AsyncIterator<Response, void> };
|
export type ServerStreamingMethodResult<Response> = { [Symbol.asyncIterator](): AsyncIterator<Response, void> };
|
||||||
|
|
||||||
|
export interface MessageFns<T> {
|
||||||
|
encode(message: T, writer?: BinaryWriter): BinaryWriter;
|
||||||
|
decode(input: BinaryReader | Uint8Array, length?: number): T;
|
||||||
|
fromJSON(object: any): T;
|
||||||
|
toJSON(message: T): unknown;
|
||||||
|
create(base?: DeepPartial<T>): T;
|
||||||
|
fromPartial(object: DeepPartial<T>): T;
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user