debop

package kesti4j

import java.util.function._

/**
  * @author sunghyouk.bae@gmail.com
  */
package object core {

  object Implicits {

debop

private static ExecutorService newExecutorService() {
        return Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
    }

    @SafeVarargs
    public static void runTasks(int count, Runnable... runnables) {

        ExecutorService executor = newExecutorService();

        try {

debop

@Configuration
@EnableCaching
@ComponentScan(basePackageClasses = UserRepository.class)
// @PropertySource("classpath:redis.properties")
public class RedisCacheConfiguration {

    @Autowired
    Environment env;

    @Bean

debop

open class AvroSerializer @JvmOverloads constructor(val codecFactory: CodecFactory = CodecFactory.snappyCodec()) {

  /**
   * Avro instance 를 직렬화하여 byte array 로 변환합니다.
   */
  fun <T : SpecificRecordBase> writeAvroObject(graph: T?): ByteArray {
    return graph?.let {
      val sdw = SpecificDatumWriter<T>(graph.schema)
      val dfw = DataFileWriter(sdw).setCodec(codecFactory)

debop

  /** 모든 수형에 대해 builder 패턴을 제공하기 위해 사용 : Kotlin 의 apply method 와 같다 */
  implicit class AnyRefExtension[T <: AnyRef](underlying: T) {
    def build(builder: T => T): T = builder(underlying)
    def let(procedure: T => Unit): Unit = procedure(underlying)
  }

  /** 모든 Option 에 대해 Kotlin 의 let 과 같은 기능을 제공한다 */
  implicit class OptionExteions[T](underlying: Option[T]) {
    def let(procedure: T => Unit): Unit = underlying foreach { procedure }
  }

debop

package kr.kth.commons.slf4j

import org.slf4j.{Logger => Slf4jLogger, Marker}
import annotation.varargs

/**
 * Scala를 위한 Logger 입니다.
 * User: sunghyouk.bae@gmail.com
 * Date: 13. 1. 6.
 */

debop

interface Product {
  val productArity: Int
  fun elements(index: Int): Any?

  fun toList(): List<*> = productIterator().toList()

  fun productIterator(): Iterator<*> = object : Iterator<Any?> {
    var currIndex = 0
    override fun hasNext(): Boolean = currIndex < productArity
    override fun next(): Any? = elements(currIndex++)

debop

data class Tuple1<out T1 : Any>(override val first: T1) : Product1<T1>, Serializable {

  override fun toString(): String {
    return "($first)"
  }
}

data class Tuple2<out T1 : Any, out T2 : Any>(
    override val first: T1,
    override val second: T2) : Product2<T1, T2>, Serializable {

debop

/*
 * Copyright (c) 2016. Sunghyouk Bae <sunghyouk.bae@gmail.com>
 * 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
 * distributed under the License is distributed on an "AS IS" BASIS,

debop

class GsCollectionsFunSuite extends AbstractCoreFunSuite {

  test("FastList collection") {
    val fastlist = FastList.newListWith[Int](1, 2, 3, 4, 5)

    val collected: FastList[Int] = fastlist.collect(new Function[Int, Int] {
      override def valueOf(obj: Int): Int = obj * obj
    })
    collected should contain allOf(1, 4, 9, 16, 25)