context.usage.example.ts

export const server = createServer({
  port: 1337,
  httpListener,
  dependencies: [
    bindTo(WsServerToken)(webSocketListener().run),
  ],
});

// ...

const example$ = r.pipe(
  r.matchPath('/'),
  r.matchType('POST'),
  r.useEffect((req$, _, { ask }) => req$.pipe(
    // ...
    tap(data => ask(WsServerToken).map(server =>
      server.sendBroadcastResponse({ type: 'EVENT', payload: data })
    )),
    // ...
  )));