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

Method Last

observable_operator.go:1406–1412  ·  view source on GitHub ↗

Last returns a new Observable which emit only last item. Cannot be run in parallel.

(opts ...Option)

Source from the content-addressed store, hash-verified

1404// Last returns a new Observable which emit only last item.
1405// Cannot be run in parallel.
1406func (o *ObservableImpl) Last(opts ...Option) OptionalSingle {
1407 return optionalSingle(o.parent, o, func() operator {
1408 return &lastOperator{
1409 empty: true,
1410 }
1411 }, true, false, opts...)
1412}
1413
1414type lastOperator struct {
1415 last Item

Callers

nothing calls this directly

Calls 1

optionalSingleFunction · 0.85

Tested by

no test coverage detected