pkgs/cloudflare-workers
pkgs/cloudflare-workers
1
0
Fork 0
mirror of https://github.com/syumai/workers.git synced 2025-03-10 17:29:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

make public stream util symbols

Browse Source
This commit is contained in:
syumai 2022-09-13 23:16:58 +09:00
parent c339993f96
commit 555b3e54bc
5 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kv.go
View File

@ -62,7 +62,7 @@ func (kv *KVNamespace) GetReader(key string, opts *KVNamespaceGetOptions) (io.Re
return nil, err
}
Global.Get("console").Call("log", v)
return convertStreamReaderToReader(v.Call("getReader")), nil
return ConvertStreamReaderToReader(v.Call("getReader")), nil
}
// KVNamespaceListOptions represents Cloudflare KV namespace list options.

2
r2object.go
View File

@ -52,7 +52,7 @@ func toR2Object(v js.Value) (*R2Object, error) {
bodyVal := v.Get("body")
var body io.Reader
if !bodyVal.IsUndefined() {
body = convertStreamReaderToReader(v.Get("body").Call("getReader"))
body = ConvertStreamReaderToReader(v.Get("body").Call("getReader"))
}
return &R2Object{
instance: v,

2
request.go
View File

@ -16,7 +16,7 @@ func toBody(streamOrNull js.Value) io.ReadCloser {
return nil
}
sr := streamOrNull.Call("getReader")
return io.NopCloser(convertStreamReaderToReader(sr))
return io.NopCloser(ConvertStreamReaderToReader(sr))
}
// toHeader converts JavaScript sides Headers to http.Header.

2
response.go
View File

@ -25,6 +25,6 @@ func toJSResponse(w *responseWriterBuffer) (js.Value, error) {
respInit.Set("status", status)
respInit.Set("statusText", http.StatusText(status))
respInit.Set("headers", toJSHeader(w.Header()))
readableStream := convertReaderToReadableStream(w.reader)
readableStream := ConvertReaderToReadableStream(w.reader)
return ResponseClass.New(readableStream, respInit), nil
}

8
stream.go
View File

@ -56,8 +56,8 @@ func (sr *streamReaderToReader) Read(p []byte) (n int, err error) {
return sr.buf.Read(p)
}
// convertStreamReaderToReader converts ReadableStreamDefaultReader to io.Reader.
func convertStreamReaderToReader(sr js.Value) io.Reader {
// ConvertStreamReaderToReader converts ReadableStreamDefaultReader to io.Reader.
func ConvertStreamReaderToReader(sr js.Value) io.Reader {
return &streamReaderToReader{
streamReader: sr,
}
@ -105,8 +105,8 @@ func (rs *readerToReadableStream) Cancel() error {
// https://deno.land/std@0.139.0/streams/conversion.ts#L5
const defaultChunkSize = 16_640
// convertReaderToReadableStream converts io.ReadCloser to ReadableStream.
func convertReaderToReadableStream(reader io.ReadCloser) js.Value {
// ConvertReaderToReadableStream converts io.ReadCloser to ReadableStream.
func ConvertReaderToReadableStream(reader io.ReadCloser) js.Value {
stream := &readerToReadableStream{
reader: reader,
chunkBuf: make([]byte, defaultChunkSize),