Report last error when invoked while destroyed.

base.js

@@ -3,13 +3,14 @@ var cadence = require('cadence')
 var delta = require('delta')
 var Destructible = require('destructible')
 var interrupt = require('interrupt').createInterrupter('staccato')
+var coalesce = require('extant')
 
 function Staccato (stream, opening) {
     this.stream = stream
     this._destructible = new Destructible('staccato')
     this._listeners = {
         open: this._open.bind(this),
-        error: this.destroy.bind(this)
+        error: this._destructible.destroy.bind(this._destructible)
     }
     this._destructible.markDestroyed(this)
     this._delta = null

package.json

@@ -22,6 +22,7 @@
     {
                             "cadence":                      "1.0.x",
                             "delta":                        "1.2.0",
+                            "extant":                       "1.0.x",
                             "interrupt":                    "5.0.x",
                             "destructible":                 "0.13.x"
     },

readable.js

@@ -31,6 +31,8 @@ Readable.prototype.read = cadence(function (async) {
             this._destructible.invokeDestructor('delta')
         }
         if (this.destroyed) {
+            // TODO Maybe we raise an exception if there is an error using
+            // an Interrupt based assert.
             // TODO Unlike Writable, reading a closed Readable will always
             // return null no matter how often you call it.
             this._readable = true

writable.js

@@ -4,15 +4,17 @@ var cadence = require('cadence')
 var delta = require('delta')
 var Staccato = require('./base')
 var interrupt = require('interrupt').createInterrupter('staccato')
+var coalesce = require('extant')
 
 function Writable (stream, opening) {
     Staccato.call(this, stream, opening)
 }
 util.inherits(Writable, Staccato)
 
 Writable.prototype.write = cadence(function (async, buffer) {
-    interrupt.assert(!this.destroyed, 'destroyed')
+    interrupt.assert(!this.destroyed, 'destroyed', coalesce(this._destructible.errors[0]))
     if (!this.stream.write(buffer)) { // <- does this 'error' if `true`?
+        interrupt.assert(!this.destroyed, 'destroyed', coalesce(this._destructible.errors[0]))
         async(function () {
             this._destructible.invokeDestructor('error')
             this._destructible.addDestructor('delta', this, '_cancel')
@@ -27,7 +29,7 @@ Writable.prototype.write = cadence(function (async, buffer) {
 })
 
 Writable.prototype.close = cadence(function (async) {
-    interrupt.assert(!this.destroyed, 'destroyed')
+    interrupt.assert(!this.destroyed, 'destroyed', coalesce(this._destructible.errors[0]))
     async(function () {
         this._destructible.invokeDestructor('error')
         this._destructible.addDestructor('delta', this, '_cancel')