internal

Documentation

Index

• Variables
• func SafeCloseDone(done chan<- struct{}) (ok bool)
• func TryDiscard(ctx context.Context, v reactor.Any)
• type InheritableRawPublisher
• type Key

Variables

var EmptySubscription = emptySubscription{}

var ErrCallOnSubscribeDuplicated = errors.New("call OnSubscribe duplicated")

Functions

func SafeCloseDone

func SafeCloseDone(done chan<- struct{}) (ok bool)

func TryDiscard

func TryDiscard(ctx context.Context, v reactor.Any)

Types

type InheritableRawPublisher

type InheritableRawPublisher interface {
	reactor.RawPublisher
	Parent() reactor.RawPublisher
}

type Key

type Key string

const (
	KeyOnDiscard Key = "onDiscard"
	KeyOnError   Key = "onError"
)