- streaming: add sub/unsub OP codes, changing from the old behavior of just giving a channels array. - streaming: properly check payloads against their data and send proper errors. - manager: add unsubscribe()
- add OP.DATA - manager: add _websockets map - manager: add basic publish logic - worker: add timestamps to published messages