diff --git a/lib/services/address/index.js b/lib/services/address/index.js
index 35c9d425..af9ff7df 100644
--- a/lib/services/address/index.js
+++ b/lib/services/address/index.js
@@ -648,7 +648,7 @@ AddressService.prototype.getInputs = function(addressStr, options, callback) {
       if (mempoolInputs) {
         for(var i = 0; i < mempoolInputs.length; i++) {
           // TODO copy
-          var newInput = mempooInputs[i];
+          var newInput = mempoolInputs[i];
           newInput.address = addressStr;
           newInput.height = -1;
           newInput.confirmations = 0;
diff --git a/test/services/address/index.unit.js b/test/services/address/index.unit.js
index e588e0e5..9bf9622d 100644
--- a/test/services/address/index.unit.js
+++ b/test/services/address/index.unit.js
@@ -412,6 +412,43 @@ describe('Address Service', function() {
       am = new AddressService({node: testnode});
     });
 
+    it('will add mempool inputs on close', function(done) {
+      var testStream = new EventEmitter();
+      var db = {
+        store: {
+          createReadStream: sinon.stub().returns(testStream)
+        }
+      }
+      var testnode = {
+        services: {
+          db: db,
+          bitcoind: {
+            on: sinon.stub()
+          }
+        }
+      };
+      var am = new AddressService({node: testnode});
+      var args = {
+        start: 15,
+        end: 12,
+        queryMempool: true
+      };
+      am.mempoolInputIndex[address] = [
+        {
+          address: address,
+          height: -1,
+          confirmations: 0
+        }
+      ]
+      am.getInputs(address, args, function(err, inputs) {
+        should.not.exist(err);
+        inputs.length.should.equal(1);
+        inputs[0].address.should.equal(address);
+        inputs[0].height.should.equal(-1);
+        done();
+      });
+      testStream.emit('close');
+    });
     it('will get inputs for an address and timestamp', function(done) {
       var testStream = new EventEmitter();
       var args = {