util

Documentation

Index

• func BufferedRead(buffer *bytes.Buffer, output []byte, reader ReadFunc) (int, error)
• func ErrIsClose(err error) bool
• func ReadPacket(conn net.Conn) ([]byte, error)
• func WritePacket(conn net.Conn, payload []byte) error
• type Future
• type Promise
  • func NewPromise[T any]() *Promise[T]
  • func (p *Promise[T]) Chan() chan T
  • func (p *Promise[T]) Complete(value T)
  • func (p *Promise[T]) Future() Future[T]
  • func (p *Promise[T]) IsFinished() bool
  • func (p *Promise[T]) Reset()
  • func (p *Promise[T]) Wait(timeout time.Duration) (*T, bool)
• type ReadFunc

Functions

func BufferedRead

func BufferedRead(buffer *bytes.Buffer, output []byte, reader ReadFunc) (int, error)

func ErrIsClose

func ErrIsClose(err error) bool

func ReadPacket

func ReadPacket(conn net.Conn) ([]byte, error)

func WritePacket

func WritePacket(conn net.Conn, payload []byte) error

Types

type Future

type Future[T any] interface {
	IsFinished() bool
	Wait(timeout time.Duration) (*T, bool)
	Chan() chan T
}

type Promise

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

func NewPromise

func NewPromise[T any]() *Promise[T]

func (*Promise[T]) Chan

func (p *Promise[T]) Chan() chan T

func (*Promise[T]) Complete

func (p *Promise[T]) Complete(value T)

func (*Promise[T]) Future

func (p *Promise[T]) Future() Future[T]

func (*Promise[T]) IsFinished

func (p *Promise[T]) IsFinished() bool

func (*Promise[T]) Reset

func (p *Promise[T]) Reset()

func (*Promise[T]) Wait

func (p *Promise[T]) Wait(timeout time.Duration) (*T, bool)

type ReadFunc

type ReadFunc func() ([]byte, error)