xchan

Documentation

Index

• Variables
• func Observe[T any](ctx context.Context, o Observer[T]) iter.Seq[T]
• func Values[T any](ctx context.Context, o Observable[T]) iter.Seq[T]
• type Cancelable
• type Observable
• type Observer
• type Subject
  • func (s *Subject[T]) CancelCause(err error)
  • func (s *Subject[T]) Observe() Observer[T]
  • func (s *Subject[T]) Send(value T)
• type ValueNotifier

Variables

var Completed = errors.New("completed")

Functions

func Observe

func Observe[T any](ctx context.Context, o Observer[T]) iter.Seq[T]

func Values

func Values[T any](ctx context.Context, o Observable[T]) iter.Seq[T]

Types

type Cancelable

type Cancelable interface {
	CancelCause(err error)
}

type Observable

type Observable[T any] interface {
	Value() <-chan T
}

type Observer

type Observer[T any] interface {
	Observable[T]
	Cancelable
	Done() <-chan struct{}
}

type Subject

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

func (*Subject[T]) CancelCause

func (s *Subject[T]) CancelCause(err error)

func (*Subject[T]) Observe

func (s *Subject[T]) Observe() Observer[T]

func (*Subject[T]) Send

func (s *Subject[T]) Send(value T)

type ValueNotifier

type ValueNotifier[T any] interface {
	Send(x T)
}