stream

Documentation

Index

• Variables
• func GetInterface() js.Value
• func GetReadStreamInterface() js.Value
• type ReadableStream
  • func NewFromJSObject(obj js.Value) (ReadableStream, error)
  • func (r ReadableStream) Cancel() (promise.Promise, error)
  • func (r ReadableStream) GetReader() (ReadableStreamDefaultReader, error)
  • func (r ReadableStream) Locked() (bool, error)
  • func (r ReadableStream) ReadableStream() ReadableStream
• type ReadableStreamDefaultReader
  • func NewReadableStreamDefaultReaderFromJSObject(obj js.Value) (ReadableStreamDefaultReader, error)
  • func (r ReadableStreamDefaultReader) AsyncRead(dataHandle func([]byte, error))
  • func (r ReadableStreamDefaultReader) Read(b []byte) (n int, err error)
  • func (r ReadableStreamDefaultReader) ReadableStreamDefaultReader() ReadableStreamDefaultReader
• type ReadableStreamDefaultReaderFrom
• type ReadableStreameFrom

Variables

var (
	//ErrNotAReadableStream ErrNotAnBlob error
	ErrNotAReadableStream = errors.New("Object is not a ReadableStream")
)

Functions

func GetInterface

func GetInterface() js.Value

GetInterface get teh JS interface of broadcast channel

func GetReadStreamInterface

func GetReadStreamInterface() js.Value

GetReadStreamInterface

Types

type ReadableStream

type ReadableStream struct {
	baseobject.BaseObject
}

func NewFromJSObject

func NewFromJSObject(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) ReadableStream

func (r ReadableStream) ReadableStream() ReadableStream

type ReadableStreamDefaultReader

type ReadableStreamDefaultReader struct {
	baseobject.BaseObject
}

func NewReadableStreamDefaultReaderFromJSObject

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

func (ReadableStreamDefaultReader) AsyncRead

func (r ReadableStreamDefaultReader) AsyncRead(dataHandle func([]byte, error))

func (ReadableStreamDefaultReader) Read

func (r ReadableStreamDefaultReader) Read(b []byte) (n int, err error)

func (ReadableStreamDefaultReader) ReadableStreamDefaultReader

func (r ReadableStreamDefaultReader) ReadableStreamDefaultReader() ReadableStreamDefaultReader

type ReadableStreamDefaultReaderFrom

type ReadableStreamDefaultReaderFrom interface {
	ReadableStreamDefaultReader() ReadableStreamDefaultReader
}

type ReadableStreameFrom

type ReadableStreameFrom interface {
	ReadableStream() ReadableStream
}