@@ -12,22 +12,22 @@ describe('Observer', function()
12
12
end )
13
13
14
14
it (' works when onNext callback parameter is passed' , function ()
15
- local observer = Rx .Observer .create (function () end )
15
+ local observer = Rx .Observer .create (function () end )
16
16
expectObserverToBeInCleanStateAndValid (observer )
17
17
end )
18
18
19
19
it (' works when onError callback parameter is passed' , function ()
20
- local observer = Rx .Observer .create (nil , function () end )
20
+ local observer = Rx .Observer .create (nil , function () end )
21
21
expectObserverToBeInCleanStateAndValid (observer )
22
22
end )
23
23
24
24
it (' works when onComplete callback parameter is passed' , function ()
25
- local observer = Rx .Observer .create (nil , nil , function () end )
25
+ local observer = Rx .Observer .create (nil , nil , function () end )
26
26
expectObserverToBeInCleanStateAndValid (observer )
27
27
end )
28
28
29
29
it (' works when all callback parameters are passed' , function ()
30
- local observer = Rx .Observer .create (function () end , function () end , function () end )
30
+ local observer = Rx .Observer .create (function () end , function () end , function () end )
31
31
expectObserverToBeInCleanStateAndValid (observer )
32
32
end )
33
33
end )
@@ -53,12 +53,12 @@ describe('Observer', function()
53
53
54
54
-- would gladly use something like to_not.fail() here but it's
55
55
-- not quite good with producing useful error messages
56
- local success = tryCall (function () observer :onNext () end , errors )
57
- tryCall (function () expect (success ).to .equal (true ) end , errors )
56
+ local success = tryCall (function () observer :onNext () end , errors )
57
+ tryCall (function () expect (success ).to .equal (true ) end , errors )
58
58
throwErrorsIfAny (errors )
59
59
end )
60
60
61
- describe (' does not call custom onError callback' , function ()
61
+ describe (' does not call custom onError callback' , function ()
62
62
it (' if observer already received completion notification' , function ()
63
63
local onNext = spy ()
64
64
local observer = Rx .Observer .create (onNext , nil , nil )
@@ -80,7 +80,7 @@ describe('Observer', function()
80
80
describe (' onError' , function ()
81
81
it (' causes an error by default if custom onError callback was not provided' , function ()
82
82
local observer = Rx .Observer .create ()
83
- expect (function () observer :onError () end ).to .fail ()
83
+ expect (function () observer :onError () end ).to .fail ()
84
84
end )
85
85
86
86
it (' calls custom onError callback if it was provided' , function ()
@@ -103,7 +103,7 @@ describe('Observer', function()
103
103
expect (observer .stopped ).to .equal (true )
104
104
end )
105
105
106
- describe (' does not call custom onError callback' , function ()
106
+ describe (' does not call custom onError callback' , function ()
107
107
it (' if observer already received completion notification' , function ()
108
108
local onError = spy ()
109
109
local observer = Rx .Observer .create (nil , onError , nil )
@@ -115,7 +115,7 @@ describe('Observer', function()
115
115
it (' if observer already received error notification' , function ()
116
116
local spyEnabled = false
117
117
local onError = spy ()
118
- local observer = Rx .Observer .create (nil , function () if spyEnabled then onError () end end , nil )
118
+ local observer = Rx .Observer .create (nil , function () if spyEnabled then onError () end end , nil )
119
119
observer :onError ()
120
120
spyEnabled = true
121
121
observer :onError ()
@@ -145,11 +145,11 @@ describe('Observer', function()
145
145
expect (observer .stopped ).to .equal (true )
146
146
end )
147
147
148
- describe (' does not call custom onCompleted callback' , function ()
148
+ describe (' does not call custom onCompleted callback' , function ()
149
149
it (' if observer already received completion notification' , function ()
150
150
local spyEnabled = false
151
151
local onCompleted = spy ()
152
- local observer = Rx .Observer .create (nil , function () if spyEnabled then onCompleted () end end , nil )
152
+ local observer = Rx .Observer .create (nil , function () if spyEnabled then onCompleted () end end , nil )
153
153
observer :onCompleted ()
154
154
spyEnabled = true
155
155
observer :onCompleted ()
@@ -158,7 +158,7 @@ describe('Observer', function()
158
158
159
159
it (' if observer already received error notification' , function ()
160
160
local onCompleted = spy ()
161
- local observer = Rx .Observer .create (nil , function () end , onCompleted )
161
+ local observer = Rx .Observer .create (nil , function () end , onCompleted )
162
162
observer :onError ()
163
163
observer :onCompleted ()
164
164
expect (# onCompleted ).to .equal (0 )
0 commit comments