Replying to Avatar Cesar Dias

Also, not sure if they support batching and split of filters, by treating relays as observables, this make relatively easy, my implementation of everything is somewhat 200 lines of code (ignoring types), it doesn't try to do everything tho, just a simple observables opening and completing, I am thinking about releasing a library with some useful pipelines for feeds that makes super easy to compose related subscriptions into the same stream (something like withEventAuthor(), withMentionedAuthors(), withQuotes(), withThreads()), everything connected, making it easier to teardown everything

Avatar
brugeman 1y ago

Sounds awesome! Is there a repo to take a look?

Reply to this note

Please Login to reply.

Discussion

Avatar
Cesar Dias 1y ago

Yes, on the core folder https://github.com/cesardeazevedo/nosotros/tree/dev2/src/core, everything is built on top of a webSocketSubject multiplex (subscribe.ts), which makes everything ridiculously easy (calling .unsubscribe() from a rxjs stream automatically sends a close message without a thought), everything chained together

Thread collapsed