filterSubgraphHandles<
TStream extends StreamHandle = StreamHandle
>(
log: EventLog<SubgraphDiscovery>,
path: Namespace| Name | Type | Description |
|---|---|---|
log* | EventLog<SubgraphDiscovery> | |
path* | Namespace | |
startAt | number | Default: 0 |
Filter a SubgraphDiscovery channel to only the direct children of a given namespace.
Returns an AsyncIterable whose iterator yields stream handles for
discoveries whose namespace is exactly one segment deeper than
path and shares it as a prefix. Iteration begins at
startAt (so each caller picks up only discoveries added
after its construction) and terminates when the underlying log
closes or fails.
The shared discovery channel (mux._discoveries).
Parent namespace whose direct children should be yielded.
Zero-based index into the discovery log to begin from.