Event-driven agent orchestration. Type-safe events, channels, sinks. @m4trix/core/matrix. Build, wire, stream.
Event-driven agents, typed events, channels, and streaming out of the box.
Type-safe agents with schema-validated events. No graphs, no global state.
AgentFactory.run().listensTo([evt]).logic(...).produce({})Wire agents to channels. One agent or a full swarm.
AgentNetwork.setup(({ registerAgent }) => ...)Effect Schema validation. Runtime safety, full inference.
AgentNetworkEvent.of('request', S.Struct({...}))Expose networks as HTTP APIs. Built-in Next.js & Express adapters.
NextEndpoint.from(network.expose({...})).handler()Named channels with HTTP stream and Kafka sinks.
createChannel('client').sink(sink.httpStream())Matrix agents, Pump streaming, React hooks. One package.
@m4trix/core/matrix | /stream | /react