Add controller dispose

[ajthinking]

Adds InputObserverController.dispose().
Useful to experiment with observers in headless code, like this example:

import { Application } from './Application'
import { coreNodeProvider } from './coreNodeProvider'
import { InMemoryStorage } from './InMemoryStorage'
import { InputObserverController } from './InputObserverController'
import { DiagramObserverStorage } from './storage/diagramObserverStorage'
import { ObserveLinkItems } from './types/ExecutionObserver'
import { RequestObserverType } from './types/InputObserveConfig'

(async () => {
  const app = new Application().register([coreNodeProvider])
  await app.boot()

  const diagram = app.getDiagramBuilder()
    .add('Signal', { count: 10})
    .add('Ignore')
    .connect()
    .get()

  const [ link ] = diagram.links

  const controller = new InputObserverController(
    new DiagramObserverStorage()
  )

  const linkObserver: ObserveLinkItems = {
    type: RequestObserverType.observeLinkItems,
    linkIds: [ link.id ],
    onReceive: (linksData) => {
      console.log('In onReceive!')
      console.log(linksData.map(l => `${l.linkId}: ${JSON.stringify(l.items)}`))
    },
    observerId: 'my-id',
  }

  controller.addLinkItemsObserver(linkObserver)

  const executor = app.getExecutor({
    diagram,
    storage: new InMemoryStorage(),
    inputObserverController: controller,
  })

  const execution = executor.execute()

  for await(const update of execution) {}
  console.log('Execution completed!')

  // without this line the script would never complete
  await controller.dispose()
  console.log('Controller disposed!')
})();

[vercel]

The latest updates on your projects. Learn more about Vercel for Git ↗︎

Name	Status	Preview	Comments	Updated (UTC)
data-story-docs	✅ Ready (Inspect)	Visit Preview	💬 Add feedback	Jan 6, 2025 4:03pm