Remove OutEndpoint::startStream and related.

They don't work as they should, and no one uses them.

Author: kevinmehall

Readme.md

@@ -242,26 +242,6 @@ If length is greater than maxPacketSize, libusb will automatically split the tra
 
 `this` in the callback is the OutEndpoint object.
 
-### .startStream(nTransfers=3, transferSize=maxPacketSize)
-Start a streaming transfer to the endpoint.
-
-The library will help you maintain `nTransfers` transfers pending in the kernel to ensure continuous data flow.
-The `drain` event is emitted when another transfer is necessary. Your `drain` handler should use the .write() method
-to start another transfer.
-
-### .write(data)
-Write `data` to the endpoint with the stream. `data` should be a buffer of length `transferSize` as passed to startStream.
-
-Delegates to .transfer(), but differs in that it updates the stream state tracking the number of requests in flight.
-
-### .stopStream()
-Stop the streaming transfer.
-
-No further `drain` events will be emitted. When all transfers have been completed, the OutEndpoint emits the `end` event.
-
-### Event: drain
-Emitted when the stream requests more data. Use the .write() method to start another transfer.
-
 ### Event: error(error)
 Emitted when the stream encounters an error.
 

test/usb.coffee

@@ -178,26 +178,6 @@ describe 'Device', ->
 					assert.ok(e == undefined, e)
 					done()
 
-			it 'should be a writableStream', (done)->
-				pkts = 0
-
-				outEndpoint.startStream 4, 64
-				outEndpoint.on 'drain', ->
-					pkts++
-
-					outEndpoint.write(new Buffer(64));
-
-					if pkts == 100
-						outEndpoint.stopStream()
-						#console.log("Stopping stream")
-
-				outEndpoint.on 'error', (e) ->
-					#console.log("Stream error", e)
-
-				outEndpoint.on 'end', ->
-					#console.log("Stream stopped")
-					done()
-
 		after (cb) ->
 			iface.release(cb)
 

usb.js

@@ -349,39 +349,3 @@ OutEndpoint.prototype.transferWithZLP = function (buf, cb) {
 		this.transfer(buf, cb);
 	}
 }
-
-
-OutEndpoint.prototype.startStream = function startStream(n_transfers, transfer_size){
-	n_transfers = n_transfers || 3;
-	transfer_size = transfer_size || this.descriptor.wMaxPacketSize;
-	this.streamActive = true;
-	this._streamTransfers = n_transfers;
-	this._pendingTransfers = 0;
-	var self = this
-	process.nextTick(function(){
-		for (var i=0; i<n_transfers; i++) self.emit('drain')
-	})
-}
-
-function out_ep_callback(err, d){
-	if (err) this.emit('error', err);
-	this._pendingTransfers--;
-	if (this._pendingTransfers < this._streamTransfers){
-		this.emit('drain');
-	}
-	if (this._pendingTransfers <= 0 && this._streamTransfers == 0){
-		this.emit('end');
-	}
-}
-
-usb.OutEndpoint.prototype.write = function write(data){
-	this.transfer(data, out_ep_callback);
-	this._pendingTransfers++;
-}
-
-usb.OutEndpoint.prototype.stopStream = function stopStream(){
-	this._streamTransfers = 0;
-	this.streamActive = false;
-	if (this._pendingTransfers === null) throw new Error('stopStream invoked on non-active stream.');
-	if (this._pendingTransfers == 0) this.emit('end');
-}