observer

Documentation

Index

• func NewObserverImpl[T interface{}](repeatInterval time.Duration) types.Observer[T]
• type ObserverImpl
  • func (h *ObserverImpl[T]) Publish(element T) bool
  • func (h *ObserverImpl[T]) PublishWithWaiting(ctx context.Context, element T)
  • func (h *ObserverImpl[T]) Release()
  • func (h *ObserverImpl[T]) Subscribe(s func(T) bool) uint64
  • func (h *ObserverImpl[T]) Unsubscribe(id uint64)

Functions

func NewObserverImpl

func NewObserverImpl[T interface{}](repeatInterval time.Duration) types.Observer[T]

Types

type ObserverImpl

type ObserverImpl[T interface{}] struct {
	// contains filtered or unexported fields
}

func (*ObserverImpl[T]) Publish

func (h *ObserverImpl[T]) Publish(element T) bool

func (*ObserverImpl[T]) PublishWithWaiting

func (h *ObserverImpl[T]) PublishWithWaiting(ctx context.Context, element T)

func (*ObserverImpl[T]) Release

func (h *ObserverImpl[T]) Release()

func (*ObserverImpl[T]) Subscribe

func (h *ObserverImpl[T]) Subscribe(s func(T) bool) uint64

func (*ObserverImpl[T]) Unsubscribe

func (h *ObserverImpl[T]) Unsubscribe(id uint64)