NiteshKant’s gists

NiteshKant / InterceptorDemoAsFunctions.java

Created March 13, 2015 21:23

	/*
	* Copyright 2015 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

NiteshKant / ManipulateRequestHeaders.java

Created March 4, 2015 19:59

	/*
	* 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

NiteshKant / ClientToServer.java

Created February 25, 2015 06:15

How to connect a client response to a server response.

	package io.reactivex.netty.examples.http;

	import io.netty.buffer.ByteBuf;
	import io.netty.handler.logging.LogLevel;
	import io.reactivex.netty.RxNetty;
	import io.reactivex.netty.protocol.http.client.HttpClientRequest;
	import io.reactivex.netty.protocol.http.client.HttpClientResponse;
	import io.reactivex.netty.protocol.http.server.HttpServerPipelineConfigurator;
	import io.reactivex.netty.protocol.http.server.HttpServerRequest;
	import io.reactivex.netty.protocol.http.server.HttpServerResponse;

NiteshKant / HelloWorldServer.java

Created February 3, 2015 21:16

Content compression

	/*
	* 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

NiteshKant / TestFM.java

Created December 22, 2014 23:08

	/*
	* 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

NiteshKant / MantisDuplicateResponseDebug.java

Created December 16, 2014 23:53

	/*
	* 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

NiteshKant / StartEurekaServer.java

Created November 17, 2014 20:53

EurekaServerWithDashboard

	package io.reactivex.lab.services;

	import java.util.HashMap;
	import java.util.HashSet;
	import java.util.Map;
	import java.util.stream.Collectors;

	import com.netflix.eureka2.interests.ChangeNotification;
	import com.netflix.eureka2.registry.InstanceInfo;
	import io.netty.buffer.ByteBuf;

NiteshKant / ExampleJersey.java

Last active August 29, 2015 14:06

Jersey Response proposal

	package com.netflix.karyon.examples.hellonoss.server.jersey;

	import io.reactivex.netty.protocol.text.sse.ServerSentEvent;
	import rx.Observable;
	import rx.functions.Action0;
	import rx.functions.Func1;

	import javax.ws.rs.GET;
	import javax.ws.rs.Path;
	import java.util.concurrent.TimeUnit;

NiteshKant / MessWithTimeout.java

Created August 18, 2014 20:39

If the client unsubscribes without getting the content, the next request reuses the connection and gets the older response.

	/*
	* 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

NiteshKant / UnicastContentSubject.java

Created August 18, 2014 17:52

UnicastContentSubject

	/*
	* 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

Nitesh Kant NiteshKant