gojsonrpc2datastreammultiplexer

type JSONRPC2DataStreamMultiplexer struct {
	PushMessageToOutsideCB func(data []byte) error

	// you must allocate buffer of size 'size' and pass it as WriteSeeker
	// by calling provide_data_destination
	OnRequestToProvideWriteSeekerCB func(
		size int64,
		provide_data_destination func(io.WriteSeeker) error,
	) error

	// Indicates what data transfer to writeseeker (passed using
	// OnRequestToProvideWriteSeekerCB) is complete.
	// If OnRequestToProvideWriteSeekerCB is nil, DefaultOnRequestToProvideWriteSeekerCB()
	// is used in it's place, which provides InMemFileFrom as io.WriteSeeker.
	// hint: you can do `x, ok := (v).(*InMemFileFrom)“ to convert io.WriteSeeker.
	// hint: use OnRequestToProvideWriteSeekerCB to create WriteSeaker:
	// it's pointer will be a link between
	// OnRequestToProvideWriteSeekerCB and OnIncommingDataTransferComplete
	OnIncommingDataTransferComplete func(io.WriteSeeker)
	// contains filtered or unexported fields
}

type JSONRPC2DataStreamMultiplexerBufferWrapper struct {
	BufferId  string
	RequestId any
	Buffer    io.ReadSeeker
	Mutex     sync.Mutex
	// contains filtered or unexported fields
}

type JSONRPC2DataStreamMultiplexer_proto_BufferInfo_Req struct {
	JSONRPC2DataStreamMultiplexer_proto_NewBufferMsg
}

type JSONRPC2DataStreamMultiplexer_proto_BufferInfo_Res struct {
	Size int64 `json:"s"`
}

type JSONRPC2DataStreamMultiplexer_proto_BufferSlice_Req struct {
	JSONRPC2DataStreamMultiplexer_proto_NewBufferMsg
	Start int64 `json:"start"`
	End   int64 `json:"end"`
}

type JSONRPC2DataStreamMultiplexer_proto_BufferSlice_Res struct {
	Data string `json:"data"` // base64 encoded
}

type JSONRPC2DataStreamMultiplexer_proto_NewBufferMsg struct {
	BufferId string `json:"id"`
}