flush

Documentation

Index

• func WithPeriod(splitFunc bufio.SplitFunc, period time.Duration) bufio.SplitFunc
• type State
  • func (s *State) Copy() *State
  • func (s *State) Func(splitFunc bufio.SplitFunc, period time.Duration) bufio.SplitFunc

Functions

func WithPeriod

func WithPeriod(splitFunc bufio.SplitFunc, period time.Duration) bufio.SplitFunc

Deprecated: [v0.88.0] Use WithFunc instead.

Types

type State

type State struct {
	LastDataChange time.Time
	LastDataLength int
}

func (*State) Copy

func (s *State) Copy() *State

func (*State) Func

func (s *State) Func(splitFunc bufio.SplitFunc, period time.Duration) bufio.SplitFunc

Func wraps a bufio.SplitFunc with a timer. When the timer expires, an incomplete token may be returned. The timer will reset any time the data parameter changes.