Skip to content

Commit 1300f65

Browse files
committed
formatting chnage
1 parent fefa85e commit 1300f65

File tree

1 file changed

+80
-80
lines changed

1 file changed

+80
-80
lines changed

ObserverPattern/Program.cs

Lines changed: 80 additions & 80 deletions
Original file line numberDiff line numberDiff line change
@@ -3,119 +3,119 @@
33

44
namespace ObserverPattern
55
{
6-
class JobPost
7-
{
8-
public string Title { get; private set; }
9-
10-
public JobPost(string title)
6+
class JobPost
117
{
12-
Title = title;
13-
}
14-
}
15-
class JobSeeker : IObserver<JobPost>
16-
{
17-
public string Name { get; private set; }
8+
public string Title { get; private set; }
189

19-
public JobSeeker(string name)
20-
{
21-
Name = name;
10+
public JobPost(string title)
11+
{
12+
Title = title;
13+
}
2214
}
23-
24-
//Method is not being called by JobPostings class currently
25-
public void OnCompleted()
15+
class JobSeeker : IObserver<JobPost>
2616
{
27-
//No Implementation
28-
}
17+
public string Name { get; private set; }
2918

30-
//Method is not being called by JobPostings class currently
31-
public void OnError(Exception error)
32-
{
33-
//No Implementation
34-
}
35-
36-
public void OnNext(JobPost value)
37-
{
38-
Console.WriteLine("Hi {0} ! New job posted: {1}", Name, value.Title);
39-
}
40-
}
19+
public JobSeeker(string name)
20+
{
21+
Name = name;
22+
}
4123

42-
class JobPostings : IObservable<JobPost>
43-
{
44-
private List<IObserver<JobPost>> mObservers;
45-
private List<JobPost> mJobPostings;
24+
//Method is not being called by JobPostings class currently
25+
public void OnCompleted()
26+
{
27+
//No Implementation
28+
}
4629

47-
public JobPostings()
48-
{
49-
mObservers = new List<IObserver<JobPost>>();
50-
mJobPostings = new List<JobPost>();
51-
}
30+
//Method is not being called by JobPostings class currently
31+
public void OnError(Exception error)
32+
{
33+
//No Implementation
34+
}
5235

53-
public IDisposable Subscribe(IObserver<JobPost> observer)
54-
{
55-
// Check whether observer is already registered. If not, add it
56-
if (!mObservers.Contains(observer))
36+
public void OnNext(JobPost value)
5737
{
58-
mObservers.Add(observer);
38+
Console.WriteLine("Hi {0} ! New job posted: {1}", Name, value.Title);
5939
}
60-
return new Unsubscriber<JobPost>(mObservers, observer);
6140
}
6241

63-
private void Notify(JobPost jobPost)
42+
class JobPostings : IObservable<JobPost>
6443
{
65-
foreach(var observer in mObservers)
44+
private List<IObserver<JobPost>> mObservers;
45+
private List<JobPost> mJobPostings;
46+
47+
public JobPostings()
6648
{
67-
observer.OnNext(jobPost);
49+
mObservers = new List<IObserver<JobPost>>();
50+
mJobPostings = new List<JobPost>();
6851
}
69-
}
7052

71-
public void AddJob(JobPost jobPost)
72-
{
73-
mJobPostings.Add(jobPost);
74-
Notify(jobPost);
75-
}
53+
public IDisposable Subscribe(IObserver<JobPost> observer)
54+
{
55+
// Check whether observer is already registered. If not, add it
56+
if (!mObservers.Contains(observer))
57+
{
58+
mObservers.Add(observer);
59+
}
60+
return new Unsubscriber<JobPost>(mObservers, observer);
61+
}
7662

77-
}
63+
private void Notify(JobPost jobPost)
64+
{
65+
foreach (var observer in mObservers)
66+
{
67+
observer.OnNext(jobPost);
68+
}
69+
}
7870

79-
internal class Unsubscriber<JobPost> : IDisposable
80-
{
81-
private List<IObserver<JobPost>> mObservers;
82-
private IObserver<JobPost> mObserver;
71+
public void AddJob(JobPost jobPost)
72+
{
73+
mJobPostings.Add(jobPost);
74+
Notify(jobPost);
75+
}
8376

84-
internal Unsubscriber(List<IObserver<JobPost>> observers, IObserver<JobPost> observer)
85-
{
86-
this.mObservers = observers;
87-
this.mObserver = observer;
8877
}
8978

90-
public void Dispose()
79+
internal class Unsubscriber<JobPost> : IDisposable
9180
{
92-
if (mObservers.Contains(mObserver))
93-
mObservers.Remove(mObserver);
81+
private List<IObserver<JobPost>> mObservers;
82+
private IObserver<JobPost> mObserver;
83+
84+
internal Unsubscriber(List<IObserver<JobPost>> observers, IObserver<JobPost> observer)
85+
{
86+
this.mObservers = observers;
87+
this.mObserver = observer;
88+
}
89+
90+
public void Dispose()
91+
{
92+
if (mObservers.Contains(mObserver))
93+
mObservers.Remove(mObserver);
94+
}
9495
}
95-
}
9696

9797

9898
class Program
9999
{
100100
static void Main(string[] args)
101101
{
102-
//Create Subscribers
103-
var johnDoe = new JobSeeker("John Doe");
104-
var janeDoe = new JobSeeker("Jane Doe");
102+
//Create Subscribers
103+
var johnDoe = new JobSeeker("John Doe");
104+
var janeDoe = new JobSeeker("Jane Doe");
105105

106-
//Create publisher and attch subscribers
107-
var jobPostings = new JobPostings();
108-
jobPostings.Subscribe(johnDoe);
109-
jobPostings.Subscribe(janeDoe);
106+
//Create publisher and attch subscribers
107+
var jobPostings = new JobPostings();
108+
jobPostings.Subscribe(johnDoe);
109+
jobPostings.Subscribe(janeDoe);
110110

111-
//Add a new job and see if subscribers get notified
112-
jobPostings.AddJob(new JobPost("Software Engineer"));
111+
//Add a new job and see if subscribers get notified
112+
jobPostings.AddJob(new JobPost("Software Engineer"));
113113

114-
//Output
115-
// Hi John Doe! New job posted: Software Engineer
116-
// Hi Jane Doe! New job posted: Software Engineer
114+
//Output
115+
// Hi John Doe! New job posted: Software Engineer
116+
// Hi Jane Doe! New job posted: Software Engineer
117117

118-
Console.ReadLine();
118+
Console.ReadLine();
119119
}
120120
}
121121
}

0 commit comments

Comments
 (0)