scanner

Documentation

Index

• func WithDelim(delim []byte) func(*Scanner)
• type Scanner
  • func NewScanner(reader io.Reader, opts ...func(*Scanner)) *Scanner
  • func (s *Scanner) Recv(ctx context.Context) (kawa.Message[[]byte], func(), error)
  • func (s *Scanner) Run(ctx context.Context) error

Functions

func WithDelim

func WithDelim(delim []byte) func(*Scanner)

Types

type Scanner

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

func NewScanner

func NewScanner(reader io.Reader, opts ...func(*Scanner)) *Scanner

func (*Scanner) Recv

func (s *Scanner) Recv(ctx context.Context) (kawa.Message[[]byte], func(), error)

func (*Scanner) Run

func (s *Scanner) Run(ctx context.Context) error