mrpastewart/platform
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

close requests

Browse source
This commit is contained in:
thosakwe 2016-09-03 08:43:34 -04:00
parent 29a682cce8
commit ab9926e1d2
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lib/server.dart
View file

@ -126,9 +126,7 @@ class AngelWebSocket {
} }
var event = handleAction(action, socket); var event = handleAction(action, socket);
if (event is Future) if (event is Future) event = await event;
event = await event;
if (event is WebSocketEvent) { if (event is WebSocketEvent) {
batchEvent(event); batchEvent(event);
@ -169,6 +167,10 @@ class AngelWebSocket {
if (!WebSocketTransformer.isUpgradeRequest(req.underlyingRequest)) if (!WebSocketTransformer.isUpgradeRequest(req.underlyingRequest))
throw new AngelHttpException.BadRequest(); throw new AngelHttpException.BadRequest();
res
..willCloseItself = true
..end();
var ws = await WebSocketTransformer.upgrade(req.underlyingRequest); var ws = await WebSocketTransformer.upgrade(req.underlyingRequest);
_clients.add(ws); _clients.add(ws);

2
pubspec.yaml
View file

@ -1,6 +1,6 @@
name: angel_websocket name: angel_websocket
description: WebSocket plugin for Angel description: WebSocket plugin for Angel
version: 1.0.0-dev+2 version: 1.0.0-dev+3
author: thosakwe <thosakwe@gmail.com> author: thosakwe <thosakwe@gmail.com>
homepage: https://github.com/angel-dart/angel_websocket homepage: https://github.com/angel-dart/angel_websocket
dependencies: dependencies: