stream

Documentation

Index

• type ReadResponse
• type ReadStream
• type Reader
  • func NewReader[T ReadResponse](stream ReadStream[T]) *Reader[T]
  • func (r *Reader[T]) Read(p []byte) (n int, err error)
• type WriteStream
• type Writer
  • func NewWriter[T any](factory func(body []byte) T, stream WriteStream[T]) *Writer[T]
  • func (w *Writer[T]) Write(p []byte) (n int, err error)

Types

type ReadResponse

type ReadResponse interface {
	GetBody() []byte
}

type ReadStream

type ReadStream[T ReadResponse] interface {
	Recv() (T, error)
}

type Reader

type Reader[T ReadResponse] struct {
	// contains filtered or unexported fields
}

func NewReader

func NewReader[T ReadResponse](stream ReadStream[T]) *Reader[T]

func (*Reader[T]) Read

func (r *Reader[T]) Read(p []byte) (n int, err error)

type WriteStream

type WriteStream[T any] interface {
	Send(sendRequest T) error
}

type Writer

type Writer[T any] struct {
	// contains filtered or unexported fields
}

func NewWriter

func NewWriter[T any](factory func(body []byte) T, stream WriteStream[T]) *Writer[T]

func (*Writer[T]) Write

func (w *Writer[T]) Write(p []byte) (n int, err error)