Package Docs
TypeScript API Reference
This package-local artifact is generated from packages/ts exports and source JSDoc. The shared graphrefly.dev shell delegates TypeScript API details to this route.
Core
- batch()
- isTerminalComplete()
- isTerminalError()
- terminalErrorValue()
- depCount()
- isTerminalNone()
- depWaves()
- depBatch()
- depLatest()
- depTerminal()
- Dispatcher
- Node
- node()
- dynamicNode()
- defaultNodeVersionHash()
- isInvalidErrorPayload()
- errorPayload()
- messageTier()
- isDeferredTier()
- isValueTier()
- isPauseBufferedTier()
- isTerminal()
- isUpAllowed()
Graph
- normalizeTopology()
- canonicalTopologyJson()
- canonicalTopologyBytes()
- withBlueprintHash()
- withBlueprintProvenance()
- graphBlueprintDiagnostics()
- reactiveCascadingCache()
- pipe()
- reachable()
- explainPath()
- validateNoIslands()
- EnvironmentDrivers
- fetchHttpDriver()
- domWebSocketDriver()
- StateNode
- Graph
- graph()
- filterObserve()
- coalesceObserve()
- describeToMermaid()
- mermaidLiveUrl()
- describeToMermaidUrl()
- describeToD2()
- describeToPretty()
- describeToAscii()
- describeToJson()
- retryPolicy()
- shouldRetry()
- nextRetryDelayMs()
- backoffDelayMs()
- restoreGraph()
- workerDerived()
Operators
- combine()
- withLatestFrom()
- zip()
- concat()
- race()
- buffer()
- bufferCount()
- sample()
- takeUntil()
- switchMap()
- mergeMap()
- flatMap()
- concatMap()
- exhaustMap()
- repeat()
- restoreRegistry()
- define()
- initNode()
- map()
- filter()
- scan()
- take()
- distinctUntilChanged()
- merge()
- reduce()
- pairwise()
- skip()
- takeWhile()
- first()
- last()
- find()
- elementAt()
- tap()
- onFirstData()
- settle()
- rescue()
- valve()
- delay()
- debounce()
- debounceTime()
- throttle()
- throttleTime()
- audit()
- auditTime()
- timeout()
- bufferTime()
Sources
- parseCron()
- matchesCron()
- fromCron()
- fromProcess()
- runProcessWithOptions()
- fromHttp()
- fromHttpWithOptions()
- fromSSE()
- fromSSEWithOptions()
- fromWebSocket()
- fromWebSocketWithOptions()
- fromWebhook()
- fromWebhookWithOptions()
- timer()
- fromTimer()
- interval()
- fromPromise()
- fromAsyncIter()
- of()
- fromIter()
- empty()
- never()
- throwError()
- fromEvent()
- fromPushNotification()
- fromAny()
- firstValueFrom()
- singleFromAny()
- fromRaf()
- fromIDBRequest()
- fromIDBTransaction()
- fromFSWatch()
- fromSpawn()
- nodeProcessDriver()
- runProcess()
- fromGitHook()
Data Structures
Storage
- appendLogKey()
- readAppendLogPage()
- appendLogStorage()
- multiWriterAppendLogStorage()
- memoryAppendLog()
- memoryMultiWriterAppendLog()
- hasStoragePutIfAbsent()
- requireStoragePutIfAbsent()
- hasStorageVersioned()
- requireStorageVersioned()
- webStorageBackend()
- memoryBackend()
- indexedDbBackend()
- indexedDbKv()
- indexedDbAppendLog()
- nowNs()
- envelopeChange()
- assertChangeEnvelope()
- changeEnvelopeCodec()
- ContentAddressedMissError
- contentAddressedKv()
- contentAddressedStorage()
- hasKvPutIfAbsent()
- requireKvPutIfAbsent()
- hasKvVersioned()
- requireKvVersioned()
- kvStorage()
- memoryKv()
- dictKv()
- listByPrefix()
- fileBackend()
- fileKv()
- fileAppendLog()
- sqliteBackend()
- sqliteKv()
- sqliteAppendLog()
- observeEventFrame()
- assertObserveEventFrame()
- observeEventFrameCodec()
- readObserveEventLogPage()
- collectionSnapshotKey()
- reactiveCollectionSnapshotFrame()
- reactiveCollectionChangeFrame()
- assertReactiveCollectionSnapshotFrame()
- assertReactiveCollectionChangeFrame()
- reactiveCollectionSnapshotFrameCodec()
- reactiveCollectionChangeFrameCodec()
- loadReactiveListState()
- loadReactiveLogState()
- loadReactiveMapState()
- loadReactiveIndexState()
- readThroughKv()
- tieredReadThrough()
- isDecimalIntegerString()
- isNonNegativeDecimalIntegerString()
- assertDecimalIntegerString()
- assertNonNegativeDecimalIntegerString()
- bigIntToDecimalString()
- bigIntToNonNegativeDecimalString()
- decimalStringToBigInt()
- nonNegativeDecimalStringToBigInt()
- walFramePrefix()
- walFrameKey()
- walFrameChecksum()
- walFrame()
- assertWalFrame()
- verifyWalFrameChecksum()
- walFrameCodec()
Adapters
- agenticMemoryRecordsSnapshotKey()
- agenticMemoryRecordSnapshotFrame()
- agenticMemoryRecordChangeFrame()
- assertAgenticMemoryRecordSnapshotFrame()
- assertAgenticMemoryRecordChangeFrame()
- loadAgenticMemoryRecordsState()
- persistAgenticMemoryRecords()
- openPersistentAgenticMemoryRecords()
- CanonicalProtobufError
- decodeCanonicalWireBridgeEnvelope()
- decodeCanonicalWireEdgeFrame()
- encodeCanonicalWireEdgeFrame()
- encodeCanonicalWireBridgeEnvelope()
- remoteCall()
- wireEdgeGroup()
- wireBridgeIdempotencyKey()
- wireBridgeEnvelope()
- wireBridge()
- wireBridgeAckDriver()
- wireBridgeProtobuf()
- remoteResponderHandler()
- remoteResponder()
- toHttp()
- toProcess()
- toWebSocket()
- webSocketSession()
- getGraphToken()
- getNodeToken()
- getNestBoundaryToken()
- nestProvider()
- fromNestReq()
- fromNestGuard()
- fromNestIntercept()
- fromNestError()
- fromNestLifecycle()
- fromNestCron()
- fromNestDiagnostics()
- fromNestWs()
- fromNestMessage()
- toNestHttp()
- GraphReq()
- GraphGuard()
- GraphIntercept()
- GraphFilter()
- GraphError()
- GraphLifecycle()
- GraphCron()
- GraphWs()
- GraphMessage()
- GraphHttpReply()
- GraphGuardDecision()
- GraphWsAck()
- GraphWsReply()
- GraphMessageReply()
- createNestGraphBoundaryRunner()
- createNestGraphBoundaryInterceptor()
- getNestBoundaryBindings()
- resolveNestMethodKey()
- bindingRequestId()
- bindingEmitOptions()
- isDataIssue()
- isHttpDataIssue()
- issueResponse()
- protocolError()
- lowerHttpReplyPayload()
- lowerProtocolError()
- sanitizeNestDiagnostic()
- OnGraphEvent()
- GraphInterval()
- provideGraphMessageBridge()
- provideGraphMessageProviders()
- createGraphMessageBridge()
- provideGraphBoundaryInterceptor()
- provideGraphGuard()
- provideGraphExceptionFilter()
- createGraphExceptionFilter()
- provideGraphGuardDeniedFilter()
- createGraphGuardDeniedFilter()
- provideGraphCronScheduler()
- provideGraphLifecycleHooks()
- provideGraphNativeHttpProviders()
- provideGraphNativeProviders()
- graphCronTarget()
- graphLifecycleTarget()
- createGraphCronController()
- GraphExceptionFilterBridge
- GraphGuardDeniedException
- isGraphGuardDeniedException()
- GraphGuardDeniedFilter
- provideGraphWsBridge()
- provideGraphWsProviders()
- createGraphWsBridge()
- attachObserveSink()
- attachObserveEventLog()
- useNodeValue()
- useNodeInput()
- useNodeRecord()
- persistReactiveCollection()
- openPersistentReactiveList()
- openPersistentReactiveLog()
- openPersistentReactiveMap()
- openPersistentReactiveIndex()
- createNodeValue()
- createNodeInput()
- createNodeRecord()
- nodeSnapshot()
- subscribeNodeValues()
- readableStore()
- writableStore()
- externalStore()
- recordReadableStore()
- zustandStore()
- jotaiAtom()
- nanoAtom()
- signalFromNode()
- nodeReadable()
- nodeWritable()
- nodeRecord()
Composition
Messaging
Cqrs
Orchestration
- requestToolProviderAdapterRun()
- toolProviderAdapterRunProjector()
- structuredAgentDecisionInterpreter()
- effectRunCompletionProjector()
- buildToolProviderExecutorOutcome()
- fakeExecutorResult()
- fakeExecutorFailure()
- fakeExecutorBlocked()
- fakeExecutorTimeout()
- fakeExecutorCanceled()
- executorOutcomeViewProjector()
- agentRequestProposalFromDecision()
- admitAgentRequestProposal()
- issueAgentRequest()
- agentRequestLedgerViews()
- requestSatisfactionProjector()
- buildToolProviderAdapterInputs()
- toolProviderAdapterInputProjector()
- localBuiltinToolProviderCatalog()
- validateToolProviderExecutionPolicy()
- resolveToolProviderExecutionPolicies()
- toolProviderPolicyResolutionProjector()
- toolProviderRunAdmissionProjector()
- toolProviderRunRetryProjector()
- effectRun()
- orchestrationMessagingRecipe()
- orchestrationMessageCommand()
- orchestrationMessageAckCommands()
- processEventOutboxCommands()
- processBundle()
- processEffectRunner()
- retryStatusBundle()
- breakerBundle()
- rateLimitBundle()
- timeoutBundle()
- constantBackoff()
- scheduledReadinessProjector()
- workQueueScheduledReadinessProjector()
- workQueueReadinessHandoffProjector()
- workQueueLeaseExpirationCommandProjector()
- orchestrationWorkQueueRecipe()
- processEffectSubmitCommand()
Patterns
Solutions
- workItemDomainActionAdmissionProjector()
- agenticMemoryBundle()
- agenticMemoryConsolidationApplicationBundle()
- agenticMemoryConsolidationBundle()
- agenticMemoryContextPackingBundle()
- agenticMemoryRecordFrame()
- assertAgenticMemoryRecordFrame()
- agenticMemoryRecordFrameCodec()
- agenticMemoryRecordCodec()
- agenticMemoryKgProjectionBundle()
- agenticMemoryRecordAdmissionBundle()
- admitAgenticMemoryRecordProposals()
- agenticMemoryRecordApplicationBundle()
- applyAgenticMemoryRecordAdmissions()
- agenticMemoryRetentionBundle()
- capabilityAdmissionProposal()
- capabilityAdmissionProjector()
- InjectedMeasureAdapter
- PrecomputedMeasureAdapter
- CellMeasureAdapter
- CapabilityMeasureAdapter
- SvgBoundsAdapter
- ImageSizeAdapter
- measureBlock()
- measureBlocks()
- computeBlockFlow()
- computeTotalHeight()
- CanvasMeasureAdapter
- canvasTextMeasurements()
- reactiveLayout()
- reactiveBlockLayout()
- reactiveFlowLayout()
- circleIntervalForBand()
- rectIntervalForBand()
- computeFlowLines()
- analyzeAndMeasure()
- computeLineBreaks()
- layoutNextLine()
- carveTextLineSlots()
- computeCharPositions()
- textMeasurementProvider()
- injectedTextMeasurements()
- precomputedTextMeasurements()
- cellTextMeasurements()
- capabilityTextMeasurements()
- readinessTextMeasurements()
- readinessMeasurements()
- imageSizeMeasurements()
- svgBoundsMeasurements()
- mergeMeasurements()
- blockAdaptersProvider()
- blockMeasurementProvider()
- nodeCanvasTextMeasurements()
- nodeCanvasPackageTextMeasurements()
- reactNativeTextMeasurements()
- reactNativeLayoutMeasurements()
- skiaTextMeasurements()
- skiaParagraphTextMeasureCapability()
- skiaReadyTextMeasurements()
- workItemDomainActionApplicationProjector()
- workItemDomainActionProposal()
- workItemDomainActionProposalIntake()
- workItemDomainActionApplyPolicy()
- workItemDomainActionCapabilityGuardProjector()
- workItemDomainActionProposalIntakeProjector()
- workItemAuthoringProjector()
- workItemCreatedFromDraft()
- workItemSpawnProposed()
- acceptanceCriteriaChanged()
- verificationPlanChanged()
- validateWorkItemEffectPlan()
- workItemEffectPlanProjector()
- validateWorkItemDraft()
- validateAcceptanceCriteria()
- validateVerificationPlan()
- workItemVerificationRequestLowerer()
- workItemVerificationResultMapper()
- workItemWorkQueueRecipe()
- workItemSubmitCommand()
- workspaceProposalRequiredInputResponseApplicationProjector()
- workspaceProposalWorkItemSpawnApplicationProjector()
- workspaceProposalWorkItemLinkApplicationProjector()
- workspaceProposalDomainActionApplicationProjector()
- recordWorkspaceProposalRequiredInputResponseOutcome()
- recordWorkspaceProposalWorkItemSpawnOutcome()
- recordWorkspaceProposalWorkItemLinkOutcome()
- recordWorkspaceProposalDomainActionOutcome()
- workspaceProposalFamilyOutcomeRef()
- projectWorkspaceProposalFamilyOutcomeIndex()
- projectWorkspaceProposalFamilyApplicationDiagnostics()
- workspaceProposalFamilyApplicationDiagnosticProjector()
- projectWorkspaceProposalRepairReviewRequests()
- workspaceProposalRepairReviewProjector()
- projectWorkspaceProposalRepairReviewStatuses()
- recordWorkspaceProposalRepairReviewDecision()
- projectWorkspaceProposalRepairReviewDecisionRecordings()
- workspaceProposalRepairReviewDecisionRecordingProjector()
- workspaceProposalRepairReviewStatusProjector()
- projectWorkspaceProposalFamilyApplicationReadModel()
- projectWorkspaceProposalFamilyApplicationReadModels()
- workspaceProposalProjectionReleaseDiagnosticProjector()
- workspaceProposalFamilyApplicationReadModelProjector()
- workspaceProposalFamilyApplicationReadModelsProjector()
- projectWorkspaceProposalFamilyOutcomeDetailSupplyResults()
- projectWorkspaceProposalFamilyOutcomeDetailSupplyResult()
- workspaceProposalFamilyOutcomeDetailSupplyProjector()
- projectWorkspaceProposalRepairActionDescriptors()
- workspaceProposalRepairActionDescriptorProjector()
- validateWorkspaceProposalRepairActionIntent()
- prepareWorkspaceProposalRepairReviewDecisionRecordingInput()
- projectWorkspaceProposalRepairSuccessorProposalIntakePreview()
- previewWorkspaceProposalRepairSuccessorProposalIntake()
- validateWorkspaceProposalRepairActionDisplayPolicyAdvisory()
- projectWorkspaceProposalRepairActionDisplayPolicyAdvisory()
- workspaceProposalRepairActionDisplayPolicyAdvisoryProjector()
- prepareWorkspaceProposalRepairSuccessorProposalReadyRequest()
- workspaceProposalRepairActionIntentProjector()
- workspaceProposalRepairSuccessorProposalIntakePreviewProjector()
- workspaceProposalRepairSuccessorProposalReadyRequestPreparationProjector()
- isWorkspaceProposalProjectionReleaseMaterial()
- validateWorkspaceProposalProjectionReleaseMaterial()
- projectWorkspaceProposalRequiredInputResponseApplication()
- projectWorkspaceProposalWorkItemSpawnApplication()
- projectWorkspaceProposalWorkItemLinkApplication()
- projectWorkspaceProposalDomainActionApplicationStatus()
- recordWorkspaceProposal()
- decideWorkspaceProposalAdmission()
- projectWorkspaceProposalApplicationStatus()
- validateWorkspaceProposalApplicationEnvelope()
- workspaceProposalApplicationFamilyRef()
- workspaceProposalDataOnlyIssues()
- assertWorkspaceProposalDataOnly()
Testing
Work Queue
Inspection
Executors
- localBuiltinToolProviderBinding()
- localBuiltinToolProviderAdapterPack()
- processToolProviderBinding()
- processToolProviderAdapterPack()
- processToolProviderCatalog()
- httpToolProviderCatalog()
- httpToolProviderRuntime()
- toolProviderExecutionRecipe()
- executorWorkQueueRecipe()
- executorSubmitCommand()
- attachToolProviderAdapterRuntime()
Json
Memory
Reactive Layout
- columnGeometry()
- sanitizeFlowContainer()
- sanitizeFlowColumns()
- sanitizeObstacles()
- blockedIntervalsForBand()
- measurementIssue()
- measurementOk()
- latestMeasurementValue()
- tryMeasureHyphenWidth()
- validMeasurementSize()
- textMeasurementFacts()
- inputNode()
- scopedName()
- isCJK()
- normalizeWhitespace()
- segmentText()
- createDefaultSegmentAdapter()
- getDefaultSegmentAdapter()
- measuredWidth()
- metricKey()
- nonNegativeFinite()
- finiteNumber()
- emitLayoutError()
- positiveFinite()
- clampDimension()
- fitSize()
- blockMaxWidth()
- resolveTextAdapter()