Rename messages to records.
Change size arguments of read/write functions to ssize_t.
Add record reading.
Add service codes for connecting and listening streams negotiation.
Implement connect_to() fully.
Implement stream connection state check.
Fully dump stream state.