lanwen

  if (!!root.EventSource) {

    /**
     * This method wraps an EventSource as an observable sequence.
     * @param {String} url The url of the server-side script.
     * @param {Observer} [openObserver] An optional observer for the 'open' event for the server side event.
     * @returns {Observable} An observable sequence which represents the data from a server-side event.
     */
    dom.fromEventSource = function (url, openObserver) {
      return new AnonymousObservable(function (observer) {

lanwen

// v2 of the great example of SSE in go by @ismasan.
// includes fixes:
//    * infinite loop ending in panic
//    * closing a client twice
//    * potentially blocked listen() from closing a connection during multiplex step.
package main

import (
	"fmt"
	"log"

lanwen

nosetests --with-profile --profile-stats-file=nose.prof
python -c "import hotshot.stats ; stats = hotshot.stats.load('nose.prof') ; stats.sort_stats('time', 'calls') ; stats.print_stats(20)"