buffered_input

README

buffered-input

Useful library for handling multiple inputs at once.

License

Licensed under the MIT License

Authors

Copyright(c) 2020 Fred Chien cfsghost@gmail.com

Documentation

Index

• type BufferedInput
  • func NewBufferedInput(options *Options) *BufferedInput
  • func (bi *BufferedInput) Close()
  • func (bi *BufferedInput) Flush() error
  • func (bi *BufferedInput) Push(data interface{})
• type DataHandlerFunc
• type Options
  • func NewOptions() *Options

Types

type BufferedInput

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

func NewBufferedInput

func NewBufferedInput(options *Options) *BufferedInput

func (*BufferedInput) Close

func (bi *BufferedInput) Close()

func (*BufferedInput) Flush

func (bi *BufferedInput) Flush() error

func (*BufferedInput) Push

func (bi *BufferedInput) Push(data interface{})

type DataHandlerFunc

type DataHandlerFunc func([]interface{})

type Options

type Options struct {
	ChunkSize  int
	ChunkCount int
	Timeout    time.Duration
	Handler    DataHandlerFunc
}

func NewOptions

func NewOptions() *Options