Method First

observable_operator.go:1053–1057

First returns new Observable which emit only first item. Cannot be run in parallel.

(opts ...Option)

// First returns new Observable which emit only first item.
// Cannot be run in parallel.
func (o *ObservableImpl) First(opts ...Option) OptionalSingle {
	return optionalSingle(o.parent, o, func() operator {
		return &firstOperator{}
	}, true, false, opts...)
}

type firstOperator struct{}