Developeroxinion.event.stream
Real-time event pipeline. Always on.
Stream is a continuous pipeline for high-frequency events. Subscribe to filtered event feeds and process them in real time — without polling, without missed signals, and without managing infrastructure.
Stable
Generally AvailableEvent · Primitives
3 modulesoxinion.signal
Inbound event capture
Receive events from any source — webhook, SDK call, sensor, or scheduled job.
oxinion.hooks
Outbound event forwarding
Register listeners that fire when a matching event arrives.
oxinion.stream← you are here
Continuous event pipeline
Subscribe to a real-time filtered feed of events. Stream is always-on — no polling, no missed signals.
Simple by design
Stream is a continuous pipeline for high-frequency events. Subscribe to filtered event feeds and process them in real time — without polling, without missed signals, and without managing infrastructure.
- 01Filter by event type, user, or any custom field
- 02WebSocket-based — sub-millisecond delivery
- 03Backpressure handling for high-frequency signals
TypeScript
1import { createOxinion } from 'oxinion';
2
3const oxinion = createOxinion({ accessToken });
4
5// Subscribe to a filtered real-time stream
6const stream = await oxinion.event.stream.subscribe({
7 filter: {
8 type: "location_update",
9 userId: "user_123"
10 },
11 onEvent: (event) => {
12 console.log("Live event:", event.type, event.payload);
13 },
14 onError: (err) => console.error(err)
15});
16
17// Unsubscribe when done
18stream.close();
Stop polling. Start streaming.
Stream delivers events the moment they happen. Build real-time experiences without the infrastructure.