rxjs-aws-sdk - npm Package Compare versions

Comparing version 1.0.0 to 1.1.0

index.d.ts

 import * as RxSimpleDB from './RxSimpleDB';
-export { RxSimpleDB };
+import * as RxSES from './RxSES';
+export { RxSimpleDB, RxSES };

index.js

@@ -5,1 +5,3 @@ "use strict";
 exports.RxSimpleDB = RxSimpleDB;
+const RxSES = require("./RxSES");
+exports.RxSES = RxSES;

package.json

 {
   "name": "rxjs-aws-sdk",
-  "version": "1.0.0",
+  "version": "1.1.0",
   "description": "",
@@ -5,0 +5,0 @@ "main": "index.js",

RxSimpleDB.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const SimpleDB = require("aws-sdk/clients/simpledb");
-const Observable_1 = require("rxjs/Observable");
+const util_1 = require("./util");
 const { assign } = Object;
 function create(config) {
-    const origSimpledb = new SimpleDB(config);
-    return ['getAttributes', 'putAttributes', 'select']
-        .reduce((result, method) => assign(result, {
-        [method]: params => rxifySimpleDBMethod(origSimpledb, method, params)
-    }), {});
+    const simpleDB = new SimpleDB(config);
+    return util_1.rxifyMultipleRequestMethods(simpleDB, [
+        'getAttributes',
+        'putAttributes',
+        'select'
+    ]);
 }
@@ -18,13 +19,1 @@ exports.create = create;
 exports.flattenAttrs = flattenAttrs;
-function rxifySimpleDBMethod(origSimpledb, methodName, params) {
-    return new Observable_1.Observable(subscriber => {
-        const request = origSimpledb[methodName](params, (err, data) => {
-            if (err) {
-                return subscriber.error(err);
-            }
-            subscriber.next(data);
-            subscriber.complete();
-        });
-        return () => request.abort();
-    });
-}

No alert changes

Improved metrics

Total package byte prevSize

3981

increased by49.66%

Number of package files

10

increased by66.67%

Lines of code

80

increased by81.82%

No dependency changes