Currently, I am in the process of learning Angular2 and RxJS by studying someone else's application. The application consists of two modules:
asObservable.ts
export function asObservable(subject: Subject) {
return new Observable(fn => subject.subscribe(fn));
}
The second module involves creating a new BehaviorSubject object in a file called todo-store.service.ts, which then sends it to the asObservable.ts module.
todo-store.service.ts
import {asObservable} from "./asObservable";
import {List} from "immutable";
import {Todo} from "./todo";
// Customized class for Todo
@Injectable()
export class TodoStore {
private _todos: BehaviorSubject<List<Todo>> = new BehaviorSubject(List([]));
get todos() {
return asObservable(this._todos);
}
loadInitialData() {
this.todoBackendService.getAllTodos()
.subscribe(
res => {
let todos = (<Object[]>res.json()).map((todo: any) =>
new Todo({id:todo.id, description:todo.description, completed: todo.completed}));
this._todos.next(List(todos));
},
err => console.log("Error retrieving Todos")
)
}
// Unnecessary code has been omitted
}
I am aiming to simplify my code by removing the asObservable.ts file and consolidating the subscribe function into a single function. However, my attempt at achieving this with the following snippet:
get todos() {
return new Observable(Subject.subscribe(this._todos));
}
Is not successful. I would greatly appreciate some guidance on how to properly execute this task and an explanation of what mistakes I may be making. Thank you!