1 write to webSocket
System.ServiceModel (1)
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (1)
1070
this.
webSocket
= webSocket;
23 references to webSocket
System.ServiceModel (23)
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (23)
1187
TD.WebSocketAsyncReadStart(this.
webSocket
.GetHashCode());
1191
Task<int> task = this.
webSocket
.ReceiveAsync(new ArraySegment<byte>(buffer, offset, count), cancellationTokenSource.Token).ContinueWith(t =>
1208
this.
webSocket
.GetHashCode(),
1258
TD.WebSocketAsyncReadStart(this.
webSocket
.GetHashCode());
1261
Task<WebSocketReceiveResult> task = this.
webSocket
.ReceiveAsync(new ArraySegment<byte>(buffer, offset, count), CancellationToken.None);
1275
this.
webSocket
.GetHashCode(),
1314
this.
webSocket
.GetHashCode(),
1319
Task task = this.
webSocket
.SendAsync(new ArraySegment<byte>(buffer, offset, count), this.outgoingMessageType, false, CancellationToken.None);
1324
TD.WebSocketAsyncWriteStop(this.
webSocket
.GetHashCode());
1343
this.
webSocket
.GetHashCode(),
1349
Task task = this.
webSocket
.SendAsync(new ArraySegment<byte>(buffer, offset, count), this.outgoingMessageType, false, cancellationTokenSource.Token).ContinueWith(t =>
1353
TD.WebSocketAsyncWriteStop(this.
webSocket
.GetHashCode());
1374
this.
webSocket
.GetHashCode(),
1381
Task task = this.
webSocket
.SendAsync(new ArraySegment<byte>(EmptyArray<byte>.Instance, 0, 0), this.outgoingMessageType, true, CancellationToken.None);
1387
TD.WebSocketAsyncWriteStop(this.
webSocket
.GetHashCode());
1396
this.
webSocket
.GetHashCode(),
1405
Task task = this.
webSocket
.SendAsync(new ArraySegment<byte>(EmptyArray<byte>.Instance, 0, 0), this.outgoingMessageType, true, cancellationTokenSource.Token);
1413
TD.WebSocketAsyncWriteStop(this.
webSocket
.GetHashCode());
1462
if (!this.endofMessageReceived && (this.
webSocket
.State == WebSocketState.Open || this.
webSocket
.State == WebSocketState.CloseSent))
1468
Task<WebSocketReceiveResult> receiveTask = this.
webSocket
.ReceiveAsync(new ArraySegment<byte>(this.initialReadBuffer.Array), CancellationToken.None);
1472
while (!this.endofMessageReceived && (this.
webSocket
.State == WebSocketState.Open || this.
webSocket
.State == WebSocketState.CloseSent));