open-rpc
diff --git a/‎README.md‎
Lines changed: 1 addition & 1 deletion b/‎README.md‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/example.ts‎
Lines changed: 4 additions & 9 deletions b/‎src/example.ts‎
Lines changed: 4 additions & 9 deletions
diff --git a/‎src/transports/Transport.ts‎
Lines changed: 0 additions & 1 deletion b/‎src/transports/Transport.ts‎
Lines changed: 0 additions & 1 deletion
diff --git a/‎src/transports/WebSocketTransport.ts‎
Lines changed: 1 addition & 10 deletions b/‎src/transports/WebSocketTransport.ts‎
Lines changed: 1 addition & 10 deletions
@@ -6,7 +6,7 @@ import { RequestManager, HTTPTransport, Client } from '@open-rpc/client-js';
 const transport = new HTTPTransport('http://localhost:8545');
 const client = new Client(new RequestManager([transport]));
 const result = await client.request(‘addition’, [2, 2]);
-// => 4
+// => { jsonrpc: '2.0', id: 1, result: 4 }
 ```
 
 ### Contributing
 
@@ -1,12 +1,7 @@
-import Client from ".";
-import RequestManager from "./RequestManager";
-import Transport from "./transports/HTTPTransport";
-
-const t = new Transport("http://localhost:8545");
-
+import { Client, RequestManager, HTTPTransport } from ".";
+const t = new HTTPTransport("http://localhost:3333");
 const c = new Client(new RequestManager([t]));
 
-// make request for eth_blockNumber
-c.request("eth_blockNumber", []).then((b: any) => {
-  console.log('in then', b); //tslint:disable-line
+c.request("addition", [2, 2]).then((result: any) => {
+  console.log('addition result: ', result); // tslint:disable-line
 });
@@ -1,4 +1,3 @@
-
 export default interface ITransport {
   connect(): Promise<any>;
   close(): void;
 
@@ -2,7 +2,7 @@ import WebSocket from "isomorphic-ws";
 import ITransport from "./Transport";
 
 class WebSocketTransport implements ITransport {
-  public connection: WebSocket | undefined;
+  public connection: WebSocket;
   constructor(uri: string) {
     this.connection = new WebSocket(uri);
   }
@@ -18,23 +18,14 @@ class WebSocketTransport implements ITransport {
     });
   }
   public onData(callback: any) {
-    if (!this.connection) {
-      return;
-    }
     this.connection.addEventListener("message", (ev: MessageEvent) => {
       callback(ev.data);
     });
   }
   public sendData(data: any) {
-    if (!this.connection) {
-      return;
-    }
     this.connection.send(data);
   }
   public close() {
-    if (!this.connection) {
-      return;
-    }
     this.connection.close();
   }
 }
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,3 @@`
`1`		`-`
`2`	`1`	`export default interface ITransport {`
`3`	`2`	`connect(): Promise<any>;`
`4`	`3`	`close(): void;`
Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@ import WebSocket from "isomorphic-ws";`
`2`	`2`	`import ITransport from "./Transport";`
`3`	`3`
`4`	`4`	`class WebSocketTransport implements ITransport {`
`5`		`- public connection: WebSocket \| undefined;`
	`5`	`+ public connection: WebSocket;`
`6`	`6`	`constructor(uri: string) {`
`7`	`7`	`this.connection = new WebSocket(uri);`
`8`	`8`	`}`
`@@ -18,23 +18,14 @@ class WebSocketTransport implements ITransport {`
`18`	`18`	`});`
`19`	`19`	`}`
`20`	`20`	`public onData(callback: any) {`
`21`		`- if (!this.connection) {`
`22`		`- return;`
`23`		`- }`
`24`	`21`	`this.connection.addEventListener("message", (ev: MessageEvent) => {`
`25`	`22`	`callback(ev.data);`
`26`	`23`	`});`
`27`	`24`	`}`
`28`	`25`	`public sendData(data: any) {`
`29`		`- if (!this.connection) {`
`30`		`- return;`
`31`		`- }`
`32`	`26`	`this.connection.send(data);`
`33`	`27`	`}`
`34`	`28`	`public close() {`
`35`		`- if (!this.connection) {`
`36`		`- return;`
`37`		`- }`
`38`	`29`	`this.connection.close();`
`39`	`30`	`}`
`40`	`31`	`}`