stream

package
v0.0.0-...-5ee457c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssertReader

func AssertReader(native goja.Value, vm *goja.Runtime) (io.Reader, bool)

Types

type NativeReaderWrapper

type NativeReaderWrapper struct {
	// contains filtered or unexported fields
}

func NewNativeReaderWrapper

func NewNativeReaderWrapper(vm *goja.Runtime, eventLoop *eventloop.EventLoop) *NativeReaderWrapper

func (*NativeReaderWrapper) Delete

func (s *NativeReaderWrapper) Delete(key string) bool

func (*NativeReaderWrapper) Get

func (s *NativeReaderWrapper) Get(key string) goja.Value

Get a property value for the key. May return nil if the property does not exist.

func (*NativeReaderWrapper) Has

func (s *NativeReaderWrapper) Has(key string) bool

func (*NativeReaderWrapper) Keys

func (s *NativeReaderWrapper) Keys() []string

func (*NativeReaderWrapper) NativeObject

func (s *NativeReaderWrapper) NativeObject() goja.Value

func (*NativeReaderWrapper) Reader

func (s *NativeReaderWrapper) Reader() io.ReadCloser

func (*NativeReaderWrapper) Reset

func (s *NativeReaderWrapper) Reset(buf []byte)

func (*NativeReaderWrapper) SameRuntime

func (s *NativeReaderWrapper) SameRuntime(vm *goja.Runtime) bool

func (*NativeReaderWrapper) Set

func (s *NativeReaderWrapper) Set(key string, val goja.Value) bool

func (*NativeReaderWrapper) WithReader

func (s *NativeReaderWrapper) WithReader(r io.ReadCloser)

type ReadableStream

type ReadableStream struct {
	// contains filtered or unexported fields
}

func (*ReadableStream) NativeStream

func (r *ReadableStream) NativeStream() goja.Value

type ResponseProxy

type ResponseProxy struct {
	// contains filtered or unexported fields
}

func (*ResponseProxy) Delete

func (r *ResponseProxy) Delete(key string) bool

func (*ResponseProxy) Get

func (r *ResponseProxy) Get(key string) goja.Value

func (*ResponseProxy) Has

func (r *ResponseProxy) Has(key string) bool

func (*ResponseProxy) Keys

func (r *ResponseProxy) Keys() []string

func (*ResponseProxy) NativeObject

func (r *ResponseProxy) NativeObject() goja.Value

func (*ResponseProxy) Set

func (r *ResponseProxy) Set(key string, val goja.Value) bool

func (*ResponseProxy) WithResponse

func (r *ResponseProxy) WithResponse(t *common.IOContext, vm *goja.Runtime, resp *http.Response)

type StreamController

type StreamController struct {
	// contains filtered or unexported fields
}

func NewController

func NewController(eventLoop *eventloop.EventLoop, symbols *polyfill.RuntimeSymbols) (*StreamController, error)

func (*StreamController) GetResponseProxy

func (s *StreamController) GetResponseProxy(t *common.IOContext) *ResponseProxy

func (*StreamController) NewReadableStreamVM

func (s *StreamController) NewReadableStreamVM(t *common.IOContext, r io.ReadCloser, vm *goja.Runtime) *ReadableStream

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL