Ben Christensen benjchristensen

## Fibonacci.java
import java.util.HashMap;

import rx.Observable;
import rx.Subscriber;

public class Fibonacci {

    public static void main(String... args) {
        // via Observable.create
        fib.take(13).forEach(System.out::println);

## cCLA
company CLA

## gist:5903281cb65b059538446584bd79dba8
individual CLA

## ReactivePullHotOnBackpressureDrop.java
import rx.Observable;
import rx.Subscriber;
import rx.schedulers.Schedulers;

/**
 * This demonstrates how to use onBackpressureDrop when a hot stream doesn't itself handle "reactive pull"
 *
 */
public class ReactivePullHotOnBackpressureDrop {

## ParallelExecution.java
import java.util.concurrent.atomic.AtomicInteger;

import rx.Observable;
import rx.Subscriber;
import rx.schedulers.Schedulers;

public class ParallelExecution {

    public static void main(String[] args) {
        //        System.out.println("------------ mergingAsync");

## Obsurvable.java
/**
 * Copyright 2014 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

## AggregatorServer.java
package lithium;

import org.reactivestreams.Publisher;

//import com.fasterxml.jackson.dataformat.cbor.CBORFactory;

import io.reactivesocket.AbstractReactiveSocket;
import io.reactivesocket.ConnectionSetupPayload;
import io.reactivesocket.Payload;
import io.reactivesocket.ReactiveSocket;

## JSONUtility.java
import static org.junit.Assert.*;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;

## index.html
<html>
	<head>
		<title>Dynamic Stacked Bar Chart using d3.js</title>
		<script src="http://mbostock.github.com/d3/d3.v2.js"></script>
		<style>
			rect.a {
				fill: green;
			}
			rect.b {
				fill: orange;

## gist:1284824
        /**
         * Use reflection to allow performing the same tests on all GETTER methods.
         *
         * @param cache
         * @param m
         * @param argArray
         * @throws IllegalAccessException
         * @throws InvocationTargetException
         */
        private void testGetMethod(Method m, Object[] argArray) throws IllegalAccessException, InvocationTargetException {
	import java.util.HashMap;

	import rx.Observable;
	import rx.Subscriber;

	public class Fibonacci {

	public static void main(String... args) {
	// via Observable.create
	fib.take(13).forEach(System.out::println);
	import rx.Observable;
	import rx.Subscriber;
	import rx.schedulers.Schedulers;

	/**
	* This demonstrates how to use onBackpressureDrop when a hot stream doesn't itself handle "reactive pull"
	*
	*/
	public class ReactivePullHotOnBackpressureDrop {
	import java.util.concurrent.atomic.AtomicInteger;

	import rx.Observable;
	import rx.Subscriber;
	import rx.schedulers.Schedulers;

	public class ParallelExecution {

	public static void main(String[] args) {
	// System.out.println("------------ mergingAsync");
	/**
	* Copyright 2014 Netflix, Inc.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	package lithium;

	import org.reactivestreams.Publisher;

	//import com.fasterxml.jackson.dataformat.cbor.CBORFactory;

	import io.reactivesocket.AbstractReactiveSocket;
	import io.reactivesocket.ConnectionSetupPayload;
	import io.reactivesocket.Payload;
	import io.reactivesocket.ReactiveSocket;
	import static org.junit.Assert.*;

	import java.util.ArrayList;
	import java.util.Arrays;
	import java.util.Collection;
	import java.util.Iterator;
	import java.util.LinkedHashMap;
	import java.util.List;
	import java.util.Map;
	import java.util.logging.Level;
	<html>
	<head>
	<title>Dynamic Stacked Bar Chart using d3.js</title>
	<script src="http://mbostock.github.com/d3/d3.v2.js"></script>
	<style>
	rect.a {
	fill: green;
	}
	rect.b {
	fill: orange;
	/**
	* Use reflection to allow performing the same tests on all GETTER methods.
	*
	* @param cache
	* @param m
	* @param argArray
	* @throws IllegalAccessException
	* @throws InvocationTargetException
	*/
	private void testGetMethod(Method m, Object[] argArray) throws IllegalAccessException, InvocationTargetException {