{"push_id":731734891,"size":1,"distinct_size":1,"ref":"refs/heads/streams","head":"cf3242519b65ca3078a4fac416b4901ccf99c781","before":"6b9ef8edd96a909b50a820337c99f2dea0955527","commits":[{"sha":"cf3242519b65ca3078a4fac416b4901ccf99c781","author":{"email":"042ee58d65c9bfc6b8cc1df7b1443801746e7fc2@nothingsatisfies.com","name":"Bent Cardan"},"message":"subclass Socket stream from Duplex base class Fixes #29\n\n• revised program interface for all send and receive operations\n• remove EventEmitter\n• new API characteristics:\n  - full blown Duplex interface: Writeable and Readable streams\n  - from `.on(‘message’, callback)` to `.on(‘data’, callback’)\n  - pipe all endpoints together from chainable  `pipe()` methods\n  - socket’s pipe() method is a flexible zmq_proxy() || nn_device()\n  - iojs streams are domain, protocol, and transport agnostic\n  - combine sockets in new ways\n\nstreams test: pipe from sub type to push type\n\n• moving messages across a pub/pull socket combo\n• pipe a thousand msgs between incompatible socket types\n\nadd some base classes\n\nbackpressure attempt\n\npush/pull backpressure: 2nd pollReceive() handles unique nn_recv() i/o\n• examples: update all as well as add transform and writablepipe\n• tests: touch up the tests so they pass\n• tests: skip standalones for now, nn_device keeps timing out\n• document sending and receiving msgs\n\nremove conflicting _read() implementations from prototype\n\ncheck out the perf hit\n\nupdates per review/comments by Nick\n\n:rocket: apply emitStream patch\n\nRevert \":rocket: apply emitStream patch\"\n\nThis reverts commit 6e84edf4ac085601f1d03fc7a32e85591ddba2e8.","distinct":true,"url":"https://api.github.com/repos/nickdesaulniers/node-nanomsg/commits/cf3242519b65ca3078a4fac416b4901ccf99c781"}]}