mattpodwysocki

var subscription = new Rx.CompositeDisposable();

var observable = Rx.Observable.fromSocket('ws://localhost:8080', 'stock-protocol');

subscription.add(
    observable.selectMany(function (value) {
        var data = JSON.parse(value.data);
        return Rx.Observable.fromArray(data.data);
    }).groupBy(function (quote) {
        return quote.symbol;

mislav

# encoding: utf-8
#
## Stupid small pure Ruby JSON parser & generator.
#
# Copyright © 2013 Mislav Marohnić
#
# Permission is hereby granted, free of charge, to any person obtaining a copy of this
# software and associated documentation files (the “Software”), to deal in the Software
# without restriction, including without limitation the rights to use, copy, modify,
# merge, publish, distribute, sublicense, and/or sell copies of the Software, and to