stream

package
v1.5.1 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrNotImplementedReadableStream = errors.New("Browser not implemented ReadableStream")
	ErrNotImplementedWritableStream = errors.New("Browser not implemented WritableStream")
	ErrNotAReadableStream           = errors.New("Object is not a ReadableStream")
	ErrNotAWritableStream           = errors.New("Object is not a WritableStream")
)

Functions

func GetRInterface 

func GetRInterface() js.Value

GetRInterface get the JS interface ReadableStream.

func GetReadableStreamDefaultReaderInterface 

func GetReadableStreamDefaultReaderInterface() js.Value

GetReadableStreamDefaultReaderInterface

func GetWInterface 

func GetWInterface() js.Value

GetWInterface get the JS interface WritableStream.

func GetWritableStreamDefaultWriterInterface 

func GetWritableStreamDefaultWriterInterface() js.Value

GetWritableStreamDefaultWriterInterface

Types

type ReadableStream 

type ReadableStream struct {
	baseobject.BaseObject
}

func NewReadableStream 

func NewReadableStream() (ReadableStream, error)

NewReadableStream Create a new ReadableStream

func NewReadableStreamFromJSObject 

func NewReadableStreamFromJSObject(obj js.Value) (ReadableStream, error)

func (ReadableStream) Cancel 

func (r ReadableStream) Cancel() (promise.Promise, error)

func (ReadableStream) GetReader 

func (r ReadableStream) GetReader() (ReadableStreamDefaultReader, error)

func (ReadableStream) Locked 

func (r ReadableStream) Locked() (bool, error)

func (ReadableStream) PipeThrough 

func (r ReadableStream) PipeThrough(t TransformStream, options ...map[string]string) (ReadableStream, error)

func (ReadableStream) PipeTo 

func (r ReadableStream) PipeTo(w WritableStream, options ...map[string]string) (promise.Promise, error)

func (ReadableStream) ReadableStream_ 

func (r ReadableStream) ReadableStream_() ReadableStream

func (ReadableStream) Tee 

func (r ReadableStream) Tee() ([]ReadableStream, error)

type ReadableStreamDefaultReader 

type ReadableStreamDefaultReader struct {
	baseobject.BaseObject
}

func NewReadableStreamDefaultReaderFromJSObject 

func NewReadableStreamDefaultReaderFromJSObject(obj js.Value) (ReadableStreamDefaultReader, error)

func (ReadableStreamDefaultReader) AsyncRead 

func (r ReadableStreamDefaultReader) AsyncRead(buffersize int, dataHandle func([]byte, int)) (promise.Promise, error)

func (ReadableStreamDefaultReader) Cancel 

func (r ReadableStreamDefaultReader) Cancel() (promise.Promise, error)

func (ReadableStreamDefaultReader) Closed 

func (r ReadableStreamDefaultReader) Closed() (promise.Promise, error)

func (ReadableStreamDefaultReader) Read 

func (w ReadableStreamDefaultReader) Read() (promise.Promise, error)

func (ReadableStreamDefaultReader) ReadableStreamDefaultReader_ 

func (r ReadableStreamDefaultReader) ReadableStreamDefaultReader_() ReadableStreamDefaultReader

func (ReadableStreamDefaultReader) ReleaseLock 

func (r ReadableStreamDefaultReader) ReleaseLock() error

type ReadableStreamDefaultReaderFrom 

type ReadableStreamDefaultReaderFrom interface {
	ReadableStreamDefaultReader_() ReadableStreamDefaultReader
}

type ReadableStreamFrom 

type ReadableStreamFrom interface {
	ReadableStream_() ReadableStream
}

type TransformStream 

type TransformStream struct {
	baseobject.BaseObject
}

func TransfertToTransformStream 

func TransfertToTransformStream(b baseobject.BaseObject) TransformStream

type WritableStream 

type WritableStream struct {
	baseobject.BaseObject
}

func NewWritableStream 

func NewWritableStream() (WritableStream, error)

NewWritableStream Create a new NewWritableStream

func NewWriteableStreamFromJSObject 

func NewWriteableStreamFromJSObject(obj js.Value) (WritableStream, error)

func (WritableStream) Abort 

func (w WritableStream) Abort(reason string) (promise.Promise, error)

func (WritableStream) Close 

func (w WritableStream) Close() (promise.Promise, error)

func (WritableStream) GetWriter 

func (w WritableStream) GetWriter() (WritableStreamDefaultWriter, error)

func (WritableStream) Locked 

func (w WritableStream) Locked() (bool, error)

func (WritableStream) WritableStream_ 

func (r WritableStream) WritableStream_() WritableStream

type WritableStreamDefaultWriter 

type WritableStreamDefaultWriter struct {
	baseobject.BaseObject
}

func NewWritableStreamDefaultWriterFromJSObject 

func NewWritableStreamDefaultWriterFromJSObject(obj js.Value) (WritableStreamDefaultWriter, error)

func (WritableStreamDefaultWriter) Abort 

func (w WritableStreamDefaultWriter) Abort(reason string) (promise.Promise, error)

func (WritableStreamDefaultWriter) Close 

func (w WritableStreamDefaultWriter) Close() (promise.Promise, error)

func (WritableStreamDefaultWriter) Closed 

func (w WritableStreamDefaultWriter) Closed() (promise.Promise, error)

func (WritableStreamDefaultWriter) DesiredSize 

func (w WritableStreamDefaultWriter) DesiredSize() (int, error)

func (WritableStreamDefaultWriter) Ready 

func (w WritableStreamDefaultWriter) Ready() (promise.Promise, error)

func (WritableStreamDefaultWriter) ReleaseLock 

func (w WritableStreamDefaultWriter) ReleaseLock() error

func (WritableStreamDefaultWriter) WritableStreamDefaultWriter_ 

func (w WritableStreamDefaultWriter) WritableStreamDefaultWriter_() WritableStreamDefaultWriter

func (WritableStreamDefaultWriter) Write 

func (w WritableStreamDefaultWriter) Write(chunk typedarray.Uint8Array) (promise.Promise, error)

type WritableStreamDefaultWriterFrom 

type WritableStreamDefaultWriterFrom interface {
	WritableStreamDefaultWriter_() WritableStreamDefaultWriter
}

type WritableStreamFrom 

type WritableStreamFrom interface {
	WritableStream_() WritableStream
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.