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

Side by Side Diff: pkg/json_rpc_2/test/client/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.client.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 responseController = new StreamController();

17 var requestController = new StreamController();

18 var client = new json_rpc.Client.withoutJson(

19 responseController.stream, requestController.sink);

20 client.listen();

21

22 expect(requestController.stream.first.then((request) {

23 expect(request, allOf([

24 containsPair('jsonrpc', '2.0'),

25 containsPair('method', 'foo')

26 ]));

27

28 responseController.add({

29 'jsonrpc': '2.0',

30 'result': 'bar',

31 'id': request['id']

32 });

33 }), completes);

34

35 client.sendRequest('foo');

36 });

37

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

39 var responseController = new StreamController();

40 var requestController = new StreamController();

41 var client = new json_rpc.Client.withoutJson(

42 responseController.stream, requestController.sink);

43

44 var hasListenCompeted = false;

45 expect(client.listen().then((_) => hasListenCompeted = true), completes);

46

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

48 expect(hasListenCompeted, isFalse);

49

50 // This should cause listen to complete.

51 return responseController.close();

52 });

53 });

54

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

56 var responseController = new StreamController();

57 var requestController = new StreamController();

58 var client = new json_rpc.Client(

59 responseController.stream, requestController.sink);

60

61 expect(client.listen(), throwsA('oh no'));

62 responseController.addError('oh no');

63 });

64

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

66 var responseController = new StreamController();

67 var requestController = new StreamController();

68 var client = new json_rpc.Client(

69 responseController.stream, requestController.sink);

70 client.listen();

71

72 expect(() => client.listen(), throwsStateError);

73 });

74

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

76 var responseController = new StreamController();

77 var requestController = new StreamController();

78 var client = new json_rpc.Client(

79 responseController.stream, requestController.sink);

80

81 expect(client.listen(), completes);

82 expect(client.close(), completes);

83

84 expect(() => responseController.stream.listen((_) {}), throwsStateError);

85 expect(requestController.isClosed, isTrue);

86 });

87

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

89 var responseController = new StreamController();

90 var requestController = new StreamController();

91 var client = new json_rpc.Client(

92 responseController.stream, requestController.sink);

93

94 expect(() => client.close(), throwsStateError);

95 });

96 }

OLD	NEW

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