Skip to content

Instantly share code, notes, and snippets.

View sergkh's full-sized avatar

Sergey Khruschak sergkh

View GitHub Profile
package fix
import scalafix.v1._
import scala.meta._
import scala.reflect.internal.Importers
import scala.collection.mutable
// Scalafix rule to migrate from sp-commons 1.8.X to 2.0.0
class MigrationToV2 extends SyntacticRule("MigrationToV2") {
final val movedModels = List("FieldModels", "BaseModels", "CcmModels", "Models", "CardModels")
var WebSocketClient = require('websocket').client;
const client = new WebSocketClient({ closeTimeout: 10 });
const deliveryRequest = {
sessionId: 'test-session',
serviceId: 'slow',
cardId: {
cin: '0000000000000000',
iin: '31045100000000'
package com.fidesmo.logging
import cats.effect.IO
import org.typelevel.log4cats.slf4j.Slf4jLogger
import com.fidesmo.dto.RequestId
trait Logging {
import Logging._
private val logger = Slf4jLogger.getLoggerFromClass[IO](getClass())
@sergkh
sergkh / mongotest.sc
Created August 11, 2017 18:03
Concurrency test
import $ivy.`com.typesafe.akka::akka-actor:2.5.3`, akka.actor._
import $ivy.`com.typesafe.akka::akka-stream:2.5.4`, akka.stream._
import $ivy.`org.reactivemongo::reactivemongo:0.12.5`, reactivemongo.api._, reactivemongo.bson._, reactivemongo.api.collections.bson._
import $ivy.`ch.qos.logback:logback-classic:1.2.3`, org.slf4j._
import java.util.concurrent.Executors
import java.util.concurrent.atomic.AtomicLong
import scala.concurrent._
import scala.concurrent.duration._
import scala.language.postfixOps
import scala.util._