We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fcb00f0 commit b0f9ed3Copy full SHA for b0f9ed3
Internal/ObservableStateBehaviour.cs
@@ -32,20 +32,25 @@ public IObservable<Unit> updateAsObservable
32
get
33
{
34
return this.UpdateAsObservable()
35
- .SkipUntil(stateBeginAsObservable)
36
- .TakeUntil(stateEndAsObservable)
37
- .Repeat();
+ .SkipUntil(stateBeginAsObservable)
+ .TakeUntil(stateEndAsObservable)
+ .Repeat();
38
}
39
40
41
+ public override void OnStateAwake()
42
+ {
43
+ stateAwakeStream.OnNext(Unit.Default);
44
+ }
45
+
46
public override void OnStateBegin()
47
- stateBeginStream.OnNext(default(Unit));
48
+ stateBeginStream.OnNext(Unit.Default);
49
50
51
public override void OnStateEnd()
52
- stateEndStream.OnNext(default(Unit));
53
+ stateEndStream.OnNext(Unit.Default);
54
55
56
0 commit comments