Chandermani chandermani

The introduction to Reactive Programming you've been missing

If you prefer to watch video tutorials with live-coding, then check out this series I recorded with the same contents as in this article: Egghead.io - Introduction to Reactive Programming.

	{
	"Id": "1-62472af4-2c5b5b25766186371734e751",
	"Duration": 17.018,
	"LimitExceeded": false,
	"Segments": [
	{
	"Id": "46160f9f1396a63a",
	"Document": {
	"id": "46160f9f1396a63a",
	"name": "DPAAS-PAY-SBX-BPME-OrderFunction",

	using System;
	using System.Collections.Generic;
	using System.Text;

	namespace DataStructures
	{
	public class Heap<T>
	{
	private T[] items;
	private int size;

	private void PrintMatrix(int[][] matrix){
	for(int i=0;i<matrix.Length;i++) {
	for(int j=0;j<matrix[0].Length;j++) {
	Console.Write(matrix[i][j] + " ");
	}
	Console.WriteLine("");
	}
	}

	private void PrintMatrix(int[,] matrix){

	import { CoreModule } from './core.module';
	import { Injectable } from '@angular/core';
	import { ExercisePlan } from '../workout-runner/model';

	@Injectable({
	providedIn: CoreModule
	})
	export class WorkoutHistoryTrackerService {
	private maxHistoryItems = 20; // Tracking last 20 exercises
	private currentWorkoutLog: WorkoutLogEntry = null;

	@Pipe({
	name: 'orderBy'
	})
	export class OrderByPipe {
	transform(value: Array<any>, args: any[]): any {
	let field: string = args[0];
	if(value==null) {
	return null;
	}
	if (field.startsWith("-")) {

	import {Injectable, EventEmitter} from 'angular2/core';
	import {Http, Headers, RequestOptions, RequestOptionsArgs, Response, RequestMethod, Request, Connection, ConnectionBackend} from 'angular2/http';
	import * as Rx from 'rxjs';


	export enum Action { QueryStart, QueryStop };

	@Injectable()
	export class AuthHttp {
	process: EventEmitter<any> = new EventEmitter<any>();

	var planEmployees = this.DB
	.Query<Xhr.Data.Model.EmployeeLeavePlanView>("WHERE LeavePlanId=@0", p.Id)
	.ToList(); //Did a ToList() to realize this query
	// Same as it was earlier

	var planEmployees = this.DB
	.Query<Xhr.Data.Model.EmployeeLeavePlanView>("WHERE LeavePlanId=@0", p.Id);

	planEmployees.ForEach(e =>
	{
	var creditHistory = this.LeavesService.GetCredits(e.ID);
	var newCredits = creditCalculator.CalculateNewCredits(processStartTime, creditHistory);

	<input type="email"
	ng-model='userEmail'
	name='email' required
	class="form-control"
	custom-remote-validator="duplicate"
	remote-validate-functions="duplicateMailRemoteCheck"
	update-on-blur=""/>