Errors Operator

Overview

Return all the errors thrown by an Observable.

This method is blocking.

errs := rxgo.Just(
	errors.New("foo"),
	errors.New("bar"),
	errors.New("baz"),
)().Errors(rxgo.WithErrorStrategy(rxgo.Continue))
fmt.Println(errs)

Output:

[foo bar baz]