unsubscription error

The following code outputs nicely while the stream is running output, but then when it's done emits an error.
##### the code

``` coffeescript

#[...]
query = new QueryStream("select * from raw_custom_entries where description ilike '%sesame%' limit 290")
stream = client.query(query)
stream.on 'end', ->
c '\n are done'
++counter
c color.red(counter)
done()
willow = rx_node.fromStream stream
# stream.pipe(JSONStream.stringify()).pipe(process.stdout)
willow.subscribe (stuff)->
c color.green('willow has stuff'), stuff

```
##### the error

> node_modules/rxjs/Subscription.js:79
> throw new UnsubscriptionError_1.UnsubscriptionError(errors);
> ^
> UnsubscriptionError: 1 errors occurred during unsubscription:
> 1) UnsubscriptionError: 1 errors occurred during unsubscription:
> 1) TypeError: "listener" argument must be a function
> at UnsubscriptionError.Error (native)
> at new UnsubscriptionError (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs/util/UnsubscriptionError.js:16:25)
> at SafeSubscriber.Subscription.unsubscribe (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs/Subscription.js:79:19)
> at SafeSubscriber.Subscriber.unsubscribe (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs/Subscriber.js:122:38)
> at SafeSubscriber.complete (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs/Subscriber.js:217:22)
> at Subscriber._complete (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs/Subscriber.js:132:26)
> at Subscriber.complete (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs/Subscriber.js:114:18)
> at Subject.complete (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs/Subject.js:83:21)
> at . (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/rxjs.node/lib/stream-subject.js:124:18)
> at emitNone (events.js:91:20)
> at emit (events.js:185:7)
> at endReadableNT (/home/wylie/Projects_Park/GlowLit/proto__200/node_modules/readable-stream/lib/_stream_readable.js:922:12)
> at _combinedTickCallback (internal/process/next_tick.js:74:11)
> at process._tickCallback (internal/process/next_tick.js:98:9)

Riproduci l’esempio CoffeeScript query-stream e ispeziona rxjs.node/lib/stream-subject.js nel percorso di completion, insieme allo stack RxJS Subscription mostrato nel report. Traccia l’errore di unsubscription e identifica il comportamento previsto quando lo stream termina; il lavoro è completato quando l’esempio termina senza il TypeError del listener e un test di regressione appropriato lo copre.

Scritto dal modello di indicizzazione a partire dal testo della issue.