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._ |