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.
filterSubgraphHandles<
TStream extends StreamHandle = StreamHandle
>(
log: EventLog<SubgraphDiscovery>,
path: Namespace,
startAt: number = 0
): AsyncIterable<TStream>| Name | Type | Description |
|---|---|---|
log* | EventLog<SubgraphDiscovery> | The shared discovery channel ( |
path* | Namespace | Parent namespace whose direct children should be yielded. |
startAt | number | Default: 0Zero-based index into the discovery log to begin from. |