☀️

Alice aliceisjustplaying

☀️

aendra-rininsland / jetstream-firehose.ts

Last active December 16, 2024 04:29

Jetstream TypeScript implementation

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

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