internal

Documentation

Index

• Variables
• func SafeCloseDone(done chan<- struct{}) (ok bool)
• func TryDiscard(ctx context.Context, v reactor.Any)
• 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 Key

type Key string

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