Skip to content

Instantly share code, notes, and snippets.

View NiteshKant's full-sized avatar

Nitesh Kant NiteshKant

278 followers · 0 following
View GitHub Profile
@NiteshKant
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
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
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
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
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
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
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
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
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
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