OLD | NEW |
| (Empty) |
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | |
2 // for details. All rights reserved. Use of this source code is governed by a | |
3 // BSD-style license that can be found in the LICENSE file. | |
4 | |
5 library shelf.hijack_test; | |
6 | |
7 import 'dart:async'; | |
8 | |
9 import 'package:unittest/unittest.dart'; | |
10 import 'package:shelf/shelf.dart'; | |
11 | |
12 import 'test_util.dart'; | |
13 | |
14 void main() { | |
15 test('hijacking a non-hijackable request throws a StateError', () { | |
16 expect(() => new Request('GET', LOCALHOST_URI).hijack((_, __) => null), | |
17 throwsStateError); | |
18 }); | |
19 | |
20 test('hijacking a hijackable request throws a HijackException and calls ' | |
21 'onHijack', () { | |
22 var request = new Request('GET', LOCALHOST_URI, | |
23 onHijack: expectAsync((callback) { | |
24 var streamController = new StreamController(); | |
25 streamController.add([1, 2, 3]); | |
26 streamController.close(); | |
27 | |
28 var sinkController = new StreamController(); | |
29 expect(sinkController.stream.first, completion(equals([4, 5, 6]))); | |
30 | |
31 callback(streamController.stream, sinkController); | |
32 })); | |
33 | |
34 expect(() => request.hijack(expectAsync((stream, sink) { | |
35 expect(stream.first, completion(equals([1, 2, 3]))); | |
36 sink.add([4, 5, 6]); | |
37 sink.close(); | |
38 })), throwsA(new isInstanceOf<HijackException>())); | |
39 }); | |
40 | |
41 test('hijacking a hijackable request twice throws a StateError', () { | |
42 // Assert that the [onHijack] callback is only called once. | |
43 var request = new Request('GET', LOCALHOST_URI, | |
44 onHijack: expectAsync((_) => null, count: 1)); | |
45 | |
46 expect(() => request.hijack((_, __) => null), | |
47 throwsA(new isInstanceOf<HijackException>())); | |
48 | |
49 expect(() => request.hijack((_, __) => null), throwsStateError); | |
50 }); | |
51 | |
52 group('calling change', () { | |
53 test('hijacking a non-hijackable request throws a StateError', () { | |
54 var request = new Request('GET', LOCALHOST_URI); | |
55 var newRequest = request.change(); | |
56 expect(() => newRequest.hijack((_, __) => null), | |
57 throwsStateError); | |
58 }); | |
59 | |
60 test('hijacking a hijackable request throws a HijackException and calls ' | |
61 'onHijack', () { | |
62 var request = new Request('GET', LOCALHOST_URI, | |
63 onHijack: expectAsync((callback) { | |
64 var streamController = new StreamController(); | |
65 streamController.add([1, 2, 3]); | |
66 streamController.close(); | |
67 | |
68 var sinkController = new StreamController(); | |
69 expect(sinkController.stream.first, completion(equals([4, 5, 6]))); | |
70 | |
71 callback(streamController.stream, sinkController); | |
72 })); | |
73 | |
74 var newRequest = request.change(); | |
75 | |
76 expect(() => newRequest.hijack(expectAsync((stream, sink) { | |
77 expect(stream.first, completion(equals([1, 2, 3]))); | |
78 sink.add([4, 5, 6]); | |
79 sink.close(); | |
80 })), throwsA(new isInstanceOf<HijackException>())); | |
81 }); | |
82 | |
83 test('hijacking the original request after calling change throws a ' | |
84 'StateError', () { | |
85 // Assert that the [onHijack] callback is only called once. | |
86 var request = new Request('GET', LOCALHOST_URI, | |
87 onHijack: expectAsync((_) => null, count: 1)); | |
88 | |
89 var newRequest = request.change(); | |
90 | |
91 expect(() => newRequest.hijack((_, __) => null), | |
92 throwsA(new isInstanceOf<HijackException>())); | |
93 | |
94 expect(() => request.hijack((_, __) => null), throwsStateError); | |
95 }); | |
96 }); | |
97 } | |
OLD | NEW |