filterObserve()

Filter a read-only observe egress stream without turning it into a graph node.

The source stream owns ordering and lifecycle; this helper only decides whether to forward each ObserveEvent and returns the source unsubscribe unchanged.

Import

import { filterObserve } from "@graphrefly/ts/graph";

Signature

function filterObserve(
  stream: ObserveStream,
  predicate: ObservePredicate,
): ObserveStream

Parameters

Parameter	Type	Description
stream	ObserveStream	stream value used by the helper.
predicate	ObservePredicate	predicate value used by the helper.

Returns

A ObserveStream value.

Example

import { filterObserve } from "@graphrefly/ts/graph";

Source

packages/ts/src/graph/inspect.ts