MCPcopy Create free account
hub / github.com/deanrad/rxfx / complete

Function complete

operators/src/queueOnlyLatest.ts:37–41  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

35
36 let workObserver: PartialObserver<[R, T]> = {
37 complete() {
38 handlerSub = nextWork?.subscribe({
39 next: nextViaMapper,
40 });
41 },
42 next: nextViaMapper,
43 error: (e) => notify.next(e),
44 };

Callers

nothing calls this directly

Calls 2

subscribeMethod · 0.80
completeMethod · 0.80

Tested by

no test coverage detected