deduplication

Documentation

Index

• type StringChan
  • func NewStringChan(bufferSize int) *StringChan
  • func (c *StringChan) Close()
  • func (c *StringChan) In() chan<- string
  • func (c *StringChan) Out() <-chan string

Types

type StringChan

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

StringChan is a deduplicating string channel

func NewStringChan

func NewStringChan(bufferSize int) *StringChan

NewStringChan creates a StringChan with the specified buffer size

func (*StringChan) Close

func (c *StringChan) Close()

Close releases all resources

func (*StringChan) In

func (c *StringChan) In() chan<- string

In returns the input channel of the deduplicator

func (*StringChan) Out

func (c *StringChan) Out() <-chan string

Out returns the output channel of the deduplicator