Function WithBackPressureStrategy

options.go:154–158

WithBackPressureStrategy sets the back pressure strategy: drop or block.

(strategy BackpressureStrategy)

// WithBackPressureStrategy sets the back pressure strategy: drop or block.
func WithBackPressureStrategy(strategy BackpressureStrategy) Option {
	return newFuncOption(func(options *funcOption) {
		options.backPressureStrategy = strategy
	})
}

// WithErrorStrategy defines how an observable should deal with error.
// This strategy is propagated to the parent observable.