observable

Documentation

Index

• type Observable
• type Observer
  • func NewObserver[T any](subscriber *Subscriber[T], listenerBufferSize int) *Observer[T]
  • func (o *Observer[T]) Close() error
  • func (o *Observer[T]) Emit(item T)
  • func (o *Observer[T]) Subscribe() (subscription Subscription[T], done <-chan struct{}, err error)
  • func (o *Observer[T]) UnSubscribe(subscription Subscription[T])
• type Subscriber
  • func NewSubscriber[T any](size int) *Subscriber[T]
  • func (s *Subscriber[T]) Close() error
  • func (s *Subscriber[T]) Emit(item T)
  • func (s *Subscriber[T]) Subscription() (subscription Subscription[T], done <-chan struct{})
• type Subscription

Types

type Observable

type Observable[T any] interface {
	Subscribe() (subscription Subscription[T], done <-chan struct{}, err error)
	UnSubscribe(subscription Subscription[T])
}

type Observer

type Observer[T any] struct {
	// contains filtered or unexported fields
}

func NewObserver

func NewObserver[T any](subscriber *Subscriber[T], listenerBufferSize int) *Observer[T]

func (*Observer[T]) Close

func (o *Observer[T]) Close() error

func (*Observer[T]) Emit

func (o *Observer[T]) Emit(item T)

func (*Observer[T]) Subscribe

func (o *Observer[T]) Subscribe() (subscription Subscription[T], done <-chan struct{}, err error)

func (*Observer[T]) UnSubscribe

func (o *Observer[T]) UnSubscribe(subscription Subscription[T])

type Subscriber

type Subscriber[T any] struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber[T any](size int) *Subscriber[T]

func (*Subscriber[T]) Close

func (s *Subscriber[T]) Close() error

func (*Subscriber[T]) Emit

func (s *Subscriber[T]) Emit(item T)

func (*Subscriber[T]) Subscription

func (s *Subscriber[T]) Subscription() (subscription Subscription[T], done <-chan struct{})

type Subscription

type Subscription[T any] <-chan T