huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

WIP

This commit is contained in:
moozzyk 2016-10-27 09:29:09 -07:00
parent 5663198733
commit 29d859b383
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Microsoft.AspNetCore.SignalR.Client.TS/LongPollingTransport.ts
View File

@ -13,17 +13,16 @@ class LongPollingTransport implements ITransport {
} }
connect(url: string, queryString: string): Promise<void> { connect(url: string, queryString: string): Promise<void> {
return Promise.resolve(); return Promise.resolve();
} }
private poll(): void { private poll(url: string): void {
this.pollXhr.open("GET", , true); this.pollXhr.open("GET", url, true);
this.pollXhr.send(); this.pollXhr.send();
this.pollXhr.onload = () => { this.pollXhr.onload = () => {
if (this.pollXhr.status >= 200 && this.pollXhr.status < 300) { if (this.pollXhr.status >= 200 && this.pollXhr.status < 300) {
this.receiveCallback(this.pollXhr.response); this.receiveCallback(this.pollXhr.response);
this.poll(); this.poll(url);
} }
else { else {
//TODO: handle error //TODO: handle error

5
src/Microsoft.AspNetCore.SignalR.Client.TS/RpcConnection.ts
View File

@ -19,9 +19,9 @@ class RpcConnection {
private transport: ITransport; private transport: ITransport;
private id: number; private id: number;
constructor(url: string, queryString: string) { constructor(url: string, queryString?: string) {
this.url = url; this.url = url;
this.queryString = queryString; this.queryString = queryString || "";
this.callbacks = new Map<string, (any) => void>(); this.callbacks = new Map<string, (any) => void>();
this.methods = new Map<string, (...args:any[]) => void>(); this.methods = new Map<string, (...args:any[]) => void>();
this.id = 0; this.id = 0;
@ -53,6 +53,7 @@ class RpcConnection {
new HttpClient().get(this.url + "/getid?" + this.queryString) new HttpClient().get(this.url + "/getid?" + this.queryString)
.then(id => { .then(id => {
this.transport = new WebSocketTransport(data => this.messageReceived(data)); this.transport = new WebSocketTransport(data => this.messageReceived(data));
//this.transport = new LongPollingTransport(data => this.messageReceived(data));
return this.transport.connect(this.url, `id=${id}`); return this.transport.connect(this.url, `id=${id}`);
}) })
.then(() => { .then(() => {