rxjs-websockets - npm Package Compare versions

Comparing version 6.0.4 to 7.0.0-alpha.1

.circleci/config.yml

@@ -26,5 +26,5 @@ # Javascript Node CircleCI 2.0 configuration file
   version: 2
-  build:
+  test:
     jobs:
       - test
 

lib/index.d.ts

 import { Observable } from 'rxjs';
-export interface Connection {
+declare type WebSocketPayload = string | ArrayBuffer | Blob;
+export interface Connection<T extends WebSocketPayload = WebSocketPayload> {
     connectionStatus: Observable<number>;
-    messages: Observable<string>;
+    messages: Observable<T>;
 }
 export interface IWebSocket {
     close(): any;
-    send(data: string | ArrayBuffer | Blob): any;
+    send(data: WebSocketPayload): any;
     onopen: ((event: any) => any) | null;
@@ -15,2 +16,3 @@ onclose: ((event: any) => any) | null;
 export declare type WebSocketFactory = (url: string, protocols?: string | string[]) => IWebSocket;
-export default function connect(url: string, input: Observable<string>, protocols?: string | string[], websocketFactory?: WebSocketFactory): Connection;
+export default function connect<T extends WebSocketPayload = WebSocketPayload>(url: string, input: Observable<WebSocketPayload>, protocols?: string | string[], websocketFactory?: WebSocketFactory): Connection<T>;
+export {};

lib/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;AAAA,6BAAgE;AAoChE,IAAM,gBAAgB,GAAG,EAAE,CAAC;AAE5B,IAAM,uBAAuB,GAAqB,UAAC,GAAW,EAAE,SAA+C;IAA/C,0BAAA,EAAA,4BAA+C;IAAiB,OAAA,IAAI,SAAS,CAAC,GAAG,EAAE,SAAS,CAAC;AAA7B,CAA6B,CAAA;AAE7J,SAAwB,OAAO,CAC7B,GAAW,EACX,KAAyB,EACzB,SAA+C,EAC/C,gBAA4D;IAD5D,0BAAA,EAAA,4BAA+C;IAC/C,iCAAA,EAAA,0CAA4D;IAE5D,IAAM,gBAAgB,GAAG,IAAI,sBAAe,CAAS,CAAC,CAAC,CAAA;IAEvD,IAAM,QAAQ,GAAG,IAAI,iBAAU,CAAS,UAAA,QAAQ;QAC9C,IAAM,MAAM,GAAG,gBAAgB,CAAC,GAAG,EAAE,SAAS,CAAC,CAAA;QAC/C,IAAI,iBAA+B,CAAA;QAEnC,IAAI,IAAI,GAAG,KAAK,CAAA;QAChB,IAAI,WAAW,GAAG,KAAK,CAAA;QAEvB,IAAM,MAAM,GAAG;YACb,IAAI,CAAE,IAAI;gBACR,OAAM;YAER,gBAAgB,CAAC,IAAI,CAAC,gBAAgB,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAC,CAAA;YACtD,IAAI,GAAG,KAAK,CAAA;QACd,CAAC,CAAA;QAED,MAAM,CAAC,MAAM,GAAG;YACd,IAAI,GAAG,IAAI,CAAA;YACX,gBAAgB,CAAC,IAAI,CAAC,gBAAgB,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAC,CAAA;YACtD,iBAAiB,GAAG,KAAK,CAAC,SAAS,CAAC,UAAA,IAAI;gBACtC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YACnB,CAAC,CAAC,CAAA;QACJ,CAAC,CAAA;QAED,MAAM,CAAC,SAAS,GAAG,UAAC,OAAsB;YACxC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,CAAA;QAC7B,CAAC,CAAA;QAED,MAAM,CAAC,OAAO,GAAG,UAAC,KAAuB;YACvC,MAAM,EAAE,CAAA;YACR,QAAQ,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAA;QAC1C,CAAC,CAAA;QAED,MAAM,CAAC,OAAO,GAAG,UAAC,KAAsB;YACtC,qEAAqE;YACrE,IAAI,CAAE,IAAI;gBACR,OAAM;YAER,MAAM,EAAE,CAAA;YACR,IAAI,WAAW;gBACb,QAAQ,CAAC,QAAQ,EAAE,CAAA;;gBAEnB,QAAQ,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC,CAAA;QAC3C,CAAC,CAAA;QAED,OAAO;YACL,WAAW,GAAG,IAAI,CAAA;YAClB,IAAI,iBAAiB;gBACnB,iBAAiB,CAAC,WAAW,EAAE,CAAA;YAEjC,IAAI,IAAI,EAAE;gBACR,MAAM,EAAE,CAAA;gBACR,MAAM,CAAC,KAAK,EAAE,CAAA;aACf;QACH,CAAC,CAAA;IACH,CAAC,CAAC,CAAA;IAEF,OAAO,EAAE,QAAQ,UAAA,EAAE,gBAAgB,kBAAA,EAAE,CAAA;AACvC,CAAC;AAjED,0BAiEC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;AAAA,6BAAgE;AAgChE,IAAM,gBAAgB,GAAG,EAAE,CAAC;AAE5B,IAAM,uBAAuB,GAAqB,UAAC,GAAW,EAAE,SAA+C;IAA/C,0BAAA,EAAA,4BAA+C;IAAiB,OAAA,IAAI,SAAS,CAAC,GAAG,EAAE,SAAS,CAAC;AAA7B,CAA6B,CAAA;AAE7J,SAAwB,OAAO,CAC7B,GAAW,EACX,KAAmC,EACnC,SAA+C,EAC/C,gBAA4D;IAD5D,0BAAA,EAAA,4BAA+C;IAC/C,iCAAA,EAAA,0CAA4D;IAE5D,IAAM,gBAAgB,GAAG,IAAI,sBAAe,CAAS,CAAC,CAAC,CAAA;IAEvD,IAAM,QAAQ,GAAG,IAAI,iBAAU,CAAI,UAAA,QAAQ;QACzC,IAAM,MAAM,GAAG,gBAAgB,CAAC,GAAG,EAAE,SAAS,CAAC,CAAA;QAC/C,IAAI,iBAA+B,CAAA;QAEnC,IAAI,IAAI,GAAG,KAAK,CAAA;QAChB,IAAI,WAAW,GAAG,KAAK,CAAA;QAEvB,IAAM,MAAM,GAAG;YACb,IAAI,CAAE,IAAI;gBACR,OAAM;YAER,gBAAgB,CAAC,IAAI,CAAC,gBAAgB,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAC,CAAA;YACtD,IAAI,GAAG,KAAK,CAAA;QACd,CAAC,CAAA;QAED,MAAM,CAAC,MAAM,GAAG;YACd,IAAI,GAAG,IAAI,CAAA;YACX,gBAAgB,CAAC,IAAI,CAAC,gBAAgB,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAC,CAAA;YACtD,iBAAiB,GAAG,KAAK,CAAC,SAAS,CAAC,UAAA,IAAI;gBACtC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YACnB,CAAC,CAAC,CAAA;QACJ,CAAC,CAAA;QAED,MAAM,CAAC,SAAS,GAAG,UAAC,OAAoB;YACtC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,CAAA;QAC7B,CAAC,CAAA;QAED,MAAM,CAAC,OAAO,GAAG,UAAC,KAAuB;YACvC,MAAM,EAAE,CAAA;YACR,QAAQ,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAA;QAC1C,CAAC,CAAA;QAED,MAAM,CAAC,OAAO,GAAG,UAAC,KAAsB;YACtC,qEAAqE;YACrE,IAAI,CAAE,IAAI;gBACR,OAAM;YAER,MAAM,EAAE,CAAA;YACR,IAAI,WAAW;gBACb,QAAQ,CAAC,QAAQ,EAAE,CAAA;;gBAEnB,QAAQ,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC,CAAA;QAC3C,CAAC,CAAA;QAED,OAAO;YACL,WAAW,GAAG,IAAI,CAAA;YAClB,IAAI,iBAAiB;gBACnB,iBAAiB,CAAC,WAAW,EAAE,CAAA;YAEjC,IAAI,IAAI,EAAE;gBACR,MAAM,EAAE,CAAA;gBACR,MAAM,CAAC,KAAK,EAAE,CAAA;aACf;QACH,CAAC,CAAA;IACH,CAAC,CAAC,CAAA;IAEF,OAAO,EAAE,QAAQ,UAAA,EAAE,gBAAgB,kBAAA,EAAE,CAAA;AACvC,CAAC;AAjED,0BAiEC"}

package.json

 {
   "name": "rxjs-websockets",
-  "version": "6.0.4",
+  "version": "7.0.0-alpha.1",
   "description": "rxjs 5 websockets library, ideal for use with angular 2",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

src/index.ts

 import { Observable, Subscription, BehaviorSubject } from 'rxjs'
 
-export interface Connection {
-  connectionStatus: Observable<number>
-  messages: Observable<string>
-}
-
 interface EventWithReason {
@@ -12,8 +7,2 @@ reason: string
 
-interface EventWithData {
-  // TODO: should be
-  // data: string | ArrayBuffer | Blob;
-  data: string
-}
-
 interface EventWithMessage {
@@ -23,5 +12,12 @@ message?: string
 
+type WebSocketPayload = string | ArrayBuffer | Blob
+
+export interface Connection<T extends WebSocketPayload = WebSocketPayload> {
+  connectionStatus: Observable<number>,
+  messages: Observable<T>,
+}
+
 export interface IWebSocket {
   close(): any
-  send(data: string | ArrayBuffer | Blob): any
+  send(data: WebSocketPayload): any
 
@@ -43,11 +39,11 @@ // TypeScript doesn't seem to apply function bivariance on each property when
 
-export default function connect(
+export default function connect<T extends WebSocketPayload = WebSocketPayload>(
   url: string,
-  input: Observable<string>,
+  input: Observable<WebSocketPayload>,
   protocols: string | string[] = defaultProtocols,
   websocketFactory: WebSocketFactory = defaultWebsocketFactory,
-): Connection {
+): Connection<T> {
   const connectionStatus = new BehaviorSubject<number>(0)
 
-  const messages = new Observable<string>(observer => {
+  const messages = new Observable<T>(observer => {
     const socket = websocketFactory(url, protocols)
@@ -75,3 +71,3 @@ let inputSubscription: Subscription
 
-    socket.onmessage = (message: EventWithData) => {
+    socket.onmessage = (message: { data: T }) => {
       observer.next(message.data)
@@ -78,0 +74,0 @@ }

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

24967

3.43%

Number of package files

14

7.69%

Number of lines in readme file

134

3.08%

Worsened metrics

Lines of code

319

-0.62%

Number of low quality alerts

2

100%

No dependency changes