nederlandskie

33 Commits 1 Branch 0 Tags 266 KiB

Author	SHA1	Message	Date
Aleksei Voronov	5128bf9d4a	Refactor streaming stuff Now we call the processor once per commit, and it's also now a commit processor, not an operation processor, so that we can update the cursor properly	2023-09-22 12:37:10 +02:00
Aleksei Voronov	93c4979c71	Keep subscription state in order to not lose messages This isn't a good way to do it though, because opreations processor is only called for each operation, so we end up not updating the cursor as often as we realistically should be. I'll refactor this slightly later	2023-09-21 12:33:17 +02:00
Aleksei Voronov	9d3cd75db9	Refactor things a little Split into proper domain components, and 3rd party service glue	2023-09-07 19:02:36 +02:00

Author

SHA1

Message

Date

Aleksei Voronov

5128bf9d4a

Refactor streaming stuff

Now we call the processor once per commit, and it's also now
a commit processor, not an operation processor, so that we can
update the cursor properly

2023-09-22 12:37:10 +02:00

Aleksei Voronov

93c4979c71

Keep subscription state in order to not lose messages

This isn't a good way to do it though, because opreations processor is only called for each operation,
so we end up not updating the cursor as often as we realistically should be.

I'll refactor this slightly later

2023-09-21 12:33:17 +02:00

Aleksei Voronov

9d3cd75db9

Refactor things a little

Split into proper domain components, and 3rd party service glue

2023-09-07 19:02:36 +02:00

Renamed from src/streaming.rs (Browse further)