devarsh

/*PromiseQueue
It provides the following functionality
1. Put promises in queue and maintain count of currently executing promises
2. Promise expiration if the timeout has expired
3. Promise caching
   Each Promise is refered by a unique key
   - if promise is already running against that same value, reference of the currently running promise will be provided.
   - if promise is already running the a new value is provided, old promise will be cancel because its result would be 
   stale now, and new promise will be spwaned and the reference would be returned.
   - if promise has already finised executing but if its available in cache, promise result will be returned wrapped in a promise.

devarsh

package main

import (
	"fmt"
	"io/ioutil"
	"net/http"
	"sync"
)

func main() {

devarsh

import React, {Component, PropTypes } from 'react'
import { withRouter } from 'react-router-dom'

class Decorated extends React.Component {
  constructor(props,context) {
    super(props,context)
    this.state = {active: false}
  }
  static propTypes = {
    to: PropTypes.oneOfType([

devarsh

#RxJS 5 Operators By Example A (soon to be) complete list of RxJS 5 operators with easy to understand explanations and runnable examples.

(I will be adding one operator per day until all are included.)

Chinese Version by: @DrakeLeung

Table of Contents

• buffer
• bufferCount