river
river copied to clipboard
Base branch for protocol v2
- [x] Define protocol and update doc #111
- [x] Design stream abstractions #118
- [x] Implement stream abstractions
- [x] ReadStream #130
- [x] WriteStream #132
- [ ] Use stream abstractions & implement protocol closing semantics
- [ ] Protocol: Implement close requests from readers
- [ ] Protocol: Implement half-close
- [ ] Simple s/Pushable/Stream replacement
- [x] Client #136
- [ ] Server #137
- [x] Update schema for INVALID_REQUEST #107
- [ ] Handle/send back INVALID_REQUEST errors
- [ ] Update docs
good review, i'll be sending some PRs and we can sync up afterwards
its time.
a couple of things left that we'll fix against main