Websocket event streaming

EventStreamServer

Websocket server that polls the event store and sends filtered events to its clients.

import {EventStreamServer} from 'ddbes'

const server = new EventStreamServer({port: 80, pollDelay: 100})

EventStream

A client for EventStreamServer that is an event emitter and an AsyncIterator. Events matching either of the provided filter sets will be sent.

const eventStream = new EventStream({
  wsUrl: 'ws://localhost',
  events: [
    {
      aggregateType: 'Cart',
      type: ['ItemAdded', 'ItemRemoved'],
    },
    {
      aggregateType: {regexp: '^Customer.'},
    },
  ],
})