sprk.so / atp
Suite of AT Protocol TypeScript libraries built on web standards
21
fork

Configure Feed

Select the types of activity you want to include in your feed.

fmt

Roscoe Rubin-Rottenberg 5fdac23d 86a09ec4

+13 -9
+13 -9
sync/firehose/index.ts
··· 250 250 if (!parsed) { 251 251 continue; 252 252 } 253 - await this.opts.runner.trackEvent(parsed.did, parsed.seq, async () => { 254 - const parsed = await this.parseEvt(evt); 255 - for (const write of parsed) { 256 - try { 257 - await this.opts.handleEvent(write); 258 - } catch (err) { 259 - this.opts.onError(new FirehoseHandlerError(err, write)); 253 + await this.opts.runner.trackEvent( 254 + parsed.did, 255 + parsed.seq, 256 + async () => { 257 + const parsed = await this.parseEvt(evt); 258 + for (const write of parsed) { 259 + try { 260 + await this.opts.handleEvent(write); 261 + } catch (err) { 262 + this.opts.onError(new FirehoseHandlerError(err, write)); 263 + } 260 264 } 261 - } 262 - }); 265 + }, 266 + ); 263 267 } else { 264 268 await this.processEvt(evt); 265 269 }