1
- import {
2
- assertEquals
3
- } from "https://deno.land/std/testing/asserts.ts" ;
4
- import { SubscriptionObserver } from "./SubscriptionObserver.ts" ;
5
- import { Subscription } from "./Subscription.ts" ;
1
+ import { assertEquals } from "https://deno.land/std/testing/asserts.ts" ;
2
+ import { SubscriptionObserver } from "../SubscriptionObserver.ts" ;
3
+ import { Subscription } from "../Subscription.ts" ;
6
4
7
5
Deno . test ( {
8
6
name : `
@@ -52,19 +50,23 @@ it should ignore error messages after unsubscription
52
50
let times = 0 ;
53
51
let errorCalled = false ;
54
52
const subscription = new Subscription ( {
55
- next ( ) { times += 1 ; } ,
56
- error ( ) { errorCalled = true ; }
57
- } )
58
- const subscriptionObserver = new SubscriptionObserver < void > ( subscription )
53
+ next ( ) {
54
+ times += 1 ;
55
+ } ,
56
+ error ( ) {
57
+ errorCalled = true ;
58
+ } ,
59
+ } ) ;
60
+ const subscriptionObserver = new SubscriptionObserver < void > ( subscription ) ;
59
61
60
62
subscriptionObserver . next ( ) ;
61
63
subscriptionObserver . next ( ) ;
62
64
subscription . unsubscribe ( ) ;
63
65
subscriptionObserver . next ( ) ;
64
66
subscriptionObserver . error ( undefined ) ;
65
67
66
- assertEquals ( times , 2 )
67
- assertEquals ( errorCalled , false )
68
+ assertEquals ( times , 2 ) ;
69
+ assertEquals ( errorCalled , false ) ;
68
70
} ) ;
69
71
70
72
Deno . test ( `
@@ -74,9 +76,13 @@ SubscriptionObserver: it should ignore complete messages after unsubscription
74
76
let completeCalled = false ;
75
77
76
78
const subscription = new Subscription ( {
77
- next ( ) { times += 1 ; } ,
78
- complete ( ) { completeCalled = true ; }
79
- } )
79
+ next ( ) {
80
+ times += 1 ;
81
+ } ,
82
+ complete ( ) {
83
+ completeCalled = true ;
84
+ } ,
85
+ } ) ;
80
86
81
87
const subscriptionObserver = new SubscriptionObserver < void > ( subscription ) ;
82
88
@@ -86,41 +92,40 @@ SubscriptionObserver: it should ignore complete messages after unsubscription
86
92
subscriptionObserver . next ( ) ;
87
93
subscriptionObserver . complete ( ) ;
88
94
89
- assertEquals ( times , 2 )
90
- assertEquals ( completeCalled , false )
95
+ assertEquals ( times , 2 ) ;
96
+ assertEquals ( completeCalled , false ) ;
91
97
} ) ;
92
98
93
99
Deno . test ( `
94
100
SubscriptionObserver:
95
101
it should not be closed when other subscriber with same observer instance completes
96
102
` , ( ) => {
97
103
const observer = {
98
- next ( ) { /*noop*/ }
99
- }
100
- const sub1 = new SubscriptionObserver ( new Subscription ( observer ) )
101
- const sub2 = new SubscriptionObserver ( new Subscription ( observer ) )
102
-
104
+ next ( ) { /*noop*/ } ,
105
+ } ;
106
+ const sub1 = new SubscriptionObserver ( new Subscription ( observer ) ) ;
107
+ const sub2 = new SubscriptionObserver ( new Subscription ( observer ) ) ;
103
108
104
109
sub2 . complete ( ) ;
105
110
106
- assertEquals ( sub1 . closed , false )
107
- assertEquals ( sub2 . closed , true )
111
+ assertEquals ( sub1 . closed , false ) ;
112
+ assertEquals ( sub2 . closed , true ) ;
108
113
} ) ;
109
114
110
115
Deno . test ( `
111
116
SubscriptionOnserver:
112
117
it should call complete observer without any arguments
113
118
` , ( ) => {
114
- let argument : any [ ] = [ ]
119
+ let argument : any [ ] = [ ] ;
115
120
116
121
const observer = {
117
122
complete : ( ...args : any [ ] ) => {
118
123
argument = args ;
119
- }
124
+ } ,
120
125
} ;
121
126
122
127
const sub1 = new SubscriptionObserver ( new Subscription ( observer ) ) ;
123
128
sub1 . complete ( ) ;
124
129
125
- assertEquals ( argument . length , 0 )
130
+ assertEquals ( argument . length , 0 ) ;
126
131
} ) ;
0 commit comments