MCPcopy Create free account
hub / github.com/ReactiveX/RxGo / Find

Method Find

observable_operator.go:1022–1028  ·  view source on GitHub ↗

Find emits the first item passing a predicate then complete.

(find Predicate, opts ...Option)

Source from the content-addressed store, hash-verified

1020
1021// Find emits the first item passing a predicate then complete.
1022func (o *ObservableImpl) Find(find Predicate, opts ...Option) OptionalSingle {
1023 return optionalSingle(o.parent, o, func() operator {
1024 return &findOperator{
1025 find: find,
1026 }
1027 }, true, true, opts...)
1028}
1029
1030type findOperator struct {
1031 find Predicate

Callers

nothing calls this directly

Calls 1

optionalSingleFunction · 0.85

Tested by

no test coverage detected