Skip to content

Instantly share code, notes, and snippets.

@akoserwal

akoserwal/index.html

Created July 15, 2018 18:17
Show Gist options
  • Save akoserwal/d53309a8f8414eb53d515469b4722d9d to your computer and use it in GitHub Desktop.
Save akoserwal/d53309a8f8414eb53d515469b4722d9d to your computer and use it in GitHub Desktop.
Download ZIP
RxJS 5 Operators // source http://jsbin.com/daquqiq
Raw
index.html
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width">
<title>RxJS 5 Operators</title>
<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>
</head>
<body>
<script id="jsbin-javascript">
console.clear();
var Subject = function() {
var self = this;
self.observers = [];
return {
subscribe: function(observer) {
self.observers.push(observer);
},
unsubscribe: function(observer) {
var index = self.observers.indexOf(observer);
if (index > -1) {
self.observers.splice(index, 1);
}
},
notify: function(observer) {
var index = self.observers.indexOf(observer);
if (index > -1) {
self.observers[index].notify(index);
}
},
notifyAll: function() {
for (var i = 0; i < self.observers.length; i++) {
self.observers[i].notify(i);
}
}
};
};
var Observer = function() {
return {
notify: function(index) {
console.log("Observer " + index + " is notified!");
}
}
}
var subject = new Subject();
var observer1 = new Observer();
var observer2 = new Observer();
var observer3 = new Observer();
var observer4 = new Observer();
subject.subscribe(observer1);
subject.subscribe(observer2);
subject.subscribe(observer3);
subject.subscribe(observer4);
subject.notifyAll();
subject.notify(observer3);
</script>
<script id="jsbin-source-javascript" type="text/javascript">console.clear();
var Subject = function() {
var self = this;
self.observers = [];
return {
subscribe: function(observer) {
self.observers.push(observer);
},
unsubscribe: function(observer) {
var index = self.observers.indexOf(observer);
if (index > -1) {
self.observers.splice(index, 1);
}
},
notify: function(observer) {
var index = self.observers.indexOf(observer);
if (index > -1) {
self.observers[index].notify(index);
}
},
notifyAll: function() {
for (var i = 0; i < self.observers.length; i++) {
self.observers[i].notify(i);
}
}
};
};
var Observer = function() {
return {
notify: function(index) {
console.log("Observer " + index + " is notified!");
}
}
}
var subject = new Subject();
var observer1 = new Observer();
var observer2 = new Observer();
var observer3 = new Observer();
var observer4 = new Observer();
subject.subscribe(observer1);
subject.subscribe(observer2);
subject.subscribe(observer3);
subject.subscribe(observer4);
subject.notifyAll();
subject.notify(observer3);</script></body>
</html>
Raw
jsbin.daquqiq.js
console.clear();
var Subject = function() {
var self = this;
self.observers = [];
return {
subscribe: function(observer) {
self.observers.push(observer);
},
unsubscribe: function(observer) {
var index = self.observers.indexOf(observer);
if (index > -1) {
self.observers.splice(index, 1);
}
},
notify: function(observer) {
var index = self.observers.indexOf(observer);
if (index > -1) {
self.observers[index].notify(index);
}
},
notifyAll: function() {
for (var i = 0; i < self.observers.length; i++) {
self.observers[i].notify(i);
}
}
};
};
var Observer = function() {
return {
notify: function(index) {
console.log("Observer " + index + " is notified!");
}
}
}
var subject = new Subject();
var observer1 = new Observer();
var observer2 = new Observer();
var observer3 = new Observer();
var observer4 = new Observer();
subject.subscribe(observer1);
subject.subscribe(observer2);
subject.subscribe(observer3);
subject.subscribe(observer4);
subject.notifyAll();
subject.notify(observer3);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment