handleloop

Documentation

Overview

Package handleloop provides clean abstractions to handle listening to channels and passing them onto event handlers.

Index

• type Loop
  • func NewLoop(dst *handler.Handler) *Loop
  • func (l *Loop) Start(src <-chan interface{})
  • func (l *Loop) Stop()

Types

type Loop

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

Loop provides a reusable event looper abstraction. It is thread-safe to use concurrently.

func NewLoop

func NewLoop(dst *handler.Handler) *Loop

func (*Loop) Start

func (l *Loop) Start(src <-chan interface{})

Start starts a new event loop. It will try to stop existing loops before.

func (*Loop) Stop

func (l *Loop) Stop()

Stop tries to stop the Loop. If the Loop is not running, then it does nothing; thus, it can be called multiple times.