☀️

Alice aliceisjustplaying

☀️

aendra-rininsland / jetstream-firehose.ts

Last active September 20, 2024 13:17

Jetstream TypeScript implementation

	import {
	getJetstreamOpsByType,
	isJetstreamCommit,
	JetstreamEvent,
	JetstreamFirehoseSubscriptionBase,
	} from "./jetstream-subscription";

	export class JetstreamFirehoseSubscription extends JetstreamFirehoseSubscriptionBase {
	async handleEvent(evt: JetstreamEvent) {
	if (!isJetstreamCommit(evt)) return;