pkg/json_rpc_2/test/server/stream_test.dart - Issue 812253002: Delete a bunch of packages that are now on GitHub.

Side by Side Diff: pkg/json_rpc_2/test/server/stream_test.dart

Issue 812253002: Delete a bunch of packages that are now on GitHub. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart

Patch Set: Un-delete http Created 6 years ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch | Annotate | Revision Log

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 json_rpc_2.test.server.stream_test;

6

7 import 'dart:async';

8

9 import 'package:unittest/unittest.dart';

10 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc;

11

12 import 'utils.dart';

13

14 void main() {

15 test(".withoutJson supports decoded stream and sink", () {

16 var requestController = new StreamController();

17 var responseController = new StreamController();

18 var server = new json_rpc.Server.withoutJson(

19 requestController.stream, responseController.sink);

20 server.listen();

21

22 server.registerMethod('foo', (params) {

23 return {'params': params.value};

24 });

25

26 requestController.add({

27 'jsonrpc': '2.0',

28 'method': 'foo',

29 'params': {'param': 'value'},

30 'id': 1234

31 });

32

33 expect(responseController.stream.first, completion(equals({

34 'jsonrpc': '2.0',

35 'result': {'params': {'param': 'value'}},

36 'id': 1234

37 })));

38 });

39

40 test(".listen returns when the controller is closed", () {

41 var requestController = new StreamController();

42 var responseController = new StreamController();

43 var server = new json_rpc.Server(

44 requestController.stream, responseController.sink);

45

46 var hasListenCompeted = false;

47 expect(server.listen().then((_) => hasListenCompeted = true), completes);

48

49 return pumpEventQueue().then((_) {

50 expect(hasListenCompeted, isFalse);

51

52 // This should cause listen to complete.

53 return requestController.close();

54 });

55 });

56

57 test(".listen returns a stream error", () {

58 var requestController = new StreamController();

59 var responseController = new StreamController();

60 var server = new json_rpc.Server(

61 requestController.stream, responseController.sink);

62

63 expect(server.listen(), throwsA('oh no'));

64 requestController.addError('oh no');

65 });

66

67 test(".listen can't be called twice", () {

68 var requestController = new StreamController();

69 var responseController = new StreamController();

70 var server = new json_rpc.Server(

71 requestController.stream, responseController.sink);

72 server.listen();

73

74 expect(() => server.listen(), throwsStateError);

75 });

76

77 test(".close cancels the stream subscription and closes the sink", () {

78 var requestController = new StreamController();

79 var responseController = new StreamController();

80 var server = new json_rpc.Server(

81 requestController.stream, responseController.sink);

82

83 expect(server.listen(), completes);

84 expect(server.close(), completes);

85

86 expect(() => requestController.stream.listen((_) {}), throwsStateError);

87 expect(responseController.isClosed, isTrue);

88 });

89

90 test(".close can't be called before .listen", () {

91 var requestController = new StreamController();

92 var responseController = new StreamController();

93 var server = new json_rpc.Server(

94 requestController.stream, responseController.sink);

95

96 expect(() => server.close(), throwsStateError);

97 });

98 }

OLD	NEW

« no previous file with comments | « pkg/json_rpc_2/test/server/server_test.dart ('k') | pkg/json_rpc_2/test/server/utils.dart » ('j') | no next file with comments »