Skip to content

Instantly share code, notes, and snippets.

Alessandro Vermeulen spockz

Block or report user

Report or block spockz

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
View ing-bank-cla
By making a contribution to this project, I certify that:
(a) The contribution was created in whole or in part by me and I
have the right to submit it under the MIT license; or
(b) The contribution is based upon previous work that, to the best
of my knowledge, is covered under an appropriate open source
license and I have the right under that license to submit that
work with modifications, whether created in whole or in part
by me, under the MIT license; or
View gist:27407e31ac6dc3f319da073ed084f159
2018-09-16 14:11:10.473 ERROR 9041 --- [io2-8888-exec-4] : Remaining data in the network buffer, can't send SSL close message, force a close with close(true) instead
at ~[tomcat-embed-core-8.5.34.jar!/:8.5.34]
at ~[tomcat-embed-core-8.5.34.jar!/:8.5.34]
at ~[tomcat-embed-core-8.5.34.jar!/:8.5.34]
at$SocketProcessor.doRun( [tomcat-embed-core-8.5.34.jar!/:8.5.34]
at [tomcat-embed-core-8.5.34.jar!/:8.5.34]
at java.util.concurrent.ThreadPoolExecutor.runWorker( [na:1.8.0_172]
at java.util.concurrent.ThreadPoolExecutor$
spockz / PoolingTest.scala
Created Aug 17, 2018
Always sees only a single transport being created, is there a better way to check (programmaticaly) how many connections were created?
View PoolingTest.scala
it should "call createTransport only once when sharing sessions" in {
val counter = new AtomicInteger
val spied =
(x: Stack.Params) => {
View client.scala
object Foo {
def withTls(hostname: String, ciphers: Array[String]): Client = {
val socketAddressToEngine: SocketAddress => Engine = {
case sa: InetSocketAddress =>
val c = Ssl.client(hostname, sa.getPort)
case _ =>
val c = Ssl.client()
spockz / HttpProxyConnectHandler.scala
Last active Jul 15, 2016
Netty3 version of HttpProxyConnectHandler
View HttpProxyConnectHandler.scala
package com.twitter.finagle.netty3.proxy
import com.twitter.finagle._
import com.twitter.finagle.client.Transporter
import com.twitter.finagle.client.Transporter.Credentials
import com.twitter.util.Base64StringEncoder
import{InetSocketAddress, SocketAddress}
import java.util.concurrent.atomic.AtomicReference
View Weird.scala
// Scala 2.11.6-2.11.8
object WeirdCompileError {
import java.util
import javax.servlet.http.HttpServletRequest
// In HttpServletRequest: public Enumeration<String> getHeaderNames();
// Error
import com.twitter.util.Function;
public class Test {
public void test() {
final PartialFunction<Tuple2<Object, Try<Response>>, scala.Boolean> decider =
new Function<Tuple2<Object,Try<Response>>, Boolean>() {
public scala.Boolean apply(Tuple2<Object, Try<Response>> v1) {
if (v1._2().isReturn()) {
View FailoveringService.scala
* Wraps two services in a new service which checks whether the {{primaryService}} is
* available and uses it when it is available. Otherwise, it will use the {{backupService}}.
class FailoveringService[Req, Rep](primaryService: Service[Req, Rep],
backupService: Service[Req, Rep])
extends Service[Req, Rep] {
override def apply(request: Req) =
import com.twitter.finagle.Service;
import com.twitter.util.Future;
import com.twitter.util.Promise;
import rx.Observable;
import rx.Observer;
import rx.Subscription;
public class Convert {
static public <Res> Future<Res> fromObservable(final Observable<Res> observable) {
View NackTest.scala
package com.twitter.finagle.httpx
import com.twitter.finagle._
import com.twitter.util.{Await, Future}
import org.junit.runner.RunWith
import org.scalatest.junit.JUnitRunner
import org.scalatest.{FunSuite, ShouldMatchers}
import scala.compat.Platform
You can’t perform that action at this time.