Result for sbt ping-benchmark
of rx-redis.
Total time: 00:04:36
Driver | Mode | Ops/s | Error |
---|---|---|---|
finagle-redis | sync | 12,188.275 | 426.685 |
finagle-redis | async | 101,368.142 | 132,961.138 |
Result for sbt ping-benchmark
of rx-redis.
Total time: 00:04:36
Driver | Mode | Ops/s | Error |
---|---|---|---|
finagle-redis | sync | 12,188.275 | 426.685 |
finagle-redis | async | 101,368.142 | 132,961.138 |
package oanda | |
import argonaut._, Argonaut._, Shapeless._ | |
import spray.json._, DefaultJsonProtocol._ | |
import scala.util.Try | |
object J { | |
sealed trait MyMessages |
import rx.Observable; | |
import rx.Scheduler; | |
import rx.schedulers.Schedulers; | |
import rx.schedulers.TestScheduler; | |
import java.io.IOException; | |
import java.util.List; | |
import java.util.concurrent.TimeUnit; | |
public final class TimersTest { |
import fj.P; | |
import fj.P2; | |
import rx.Observable; | |
import rx.Subscriber; | |
public final class SlidingWindow { | |
public static Observable<P2<Integer, Integer>> viaScan(final Observable<Integer> integers) { | |
// allocate new Integer outside of integer cache range, so that it can be compared using `==` | |
// noinspection UnnecessaryBoxing |
module Main where | |
import Data.Char | |
import Data.List | |
main :: IO () | |
main = print | |
. maximum . map product | |
. filter((==13) . length) . map (take 13) . tails | |
. map digitToInt |
package example.statemachine | |
import scalaz.{State, Scalaz}, Scalaz._ | |
object FSM { | |
def apply[I, S](f: PartialFunction[(I, S), S]): FSM[I, S] = | |
new FSM((i, s) => f.applyOrElse((i, s), (_: (I, S)) => s)) | |
private def states[S, O](xs: List[State[S, O]]): State[S, List[O]] = | |
xs.sequence[({type λ[α]=State[S, α]})#λ, O] |
I hereby claim:
To claim this, I am signing this object:
package org.example; | |
import org.apache.lucene.document.Document; | |
import org.apache.lucene.document.Field; | |
import org.apache.lucene.document.LongField; | |
import org.apache.lucene.index.DirectoryReader; | |
import org.apache.lucene.index.IndexReader; | |
import org.apache.lucene.index.IndexWriter; | |
import org.apache.lucene.index.IndexWriterConfig; |
[info] Starting scala interpreter... | |
[info] | |
Welcome to Scala version 2.10.4 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0). | |
Type in expressions to have them evaluated. | |
Type :help for more information. | |
scala> import spray.json._ | |
import spray.json._ | |
scala> import DefaultJsonProtocol._ |