cakper

cat ~/.ammonite/predef.sc
import java.time._
import scala.concurrent.duration._
import scala.concurrent._

import $ivy.`io.monix::monix:3.0.0`

import monix.execution.Scheduler.Implicits.global
import monix.eval._
import monix.execution._

cakper

private def send(records: Seq[ProducerRecord[String, V]]): Task[Seq[RecordMetadata]] =
      Task.create[Seq[RecordMetadata]] { (s, cb) =>
        val results             = TrieMap.empty[Long, RecordMetadata]
        val expectedSize        = records.size
        val asyncCb             = Callback.forked(cb)(s)
        val compositeCancelable = CompositeCancelable()

        // Forcing asynchronous boundary
        sc.executeAsync(() => {
          records.foreach { record =>

cakper

<?xml version="1.0" encoding="UTF-8"?>

<project name="SS" default="build">
 <target name="build"
   depends="prepare,lint,phploc,pdepend,phpmd-ci,phpcs-ci,phpcpd,phpunit,phpcb"/>

 <target name="build-parallel"
   depends="prepare,lint,tools-parallel,phpunit,phpcb"/>

 <target name="tools-parallel"

cakper

  implicit class TaskExtenstions[A](val task: Task[A]) extends AnyVal {
    def timed(): Task[A] = {
      for {
        startTime <- Task.eval(nanoTime())
        result    <- task.doOnFinish {
          case _ => logger.info(nanoTime() - startTime)
        }
      } yield result
    }
  }

cakper

#!/bin/sh

if [ -f ./bin/phpspec ]
then
    ./bin/phpspec run --quiet
    if [ $? -ne 0 ]
    then
       echo "PHPSpec has failed - commit aborted"
       return 1
    fi

cakper

<?php 

$query = $em->createQuery('SELECT t FROM JazzyTransactionBundle:MoneyTransaction t WHERE t.sender = :user')->setParameter('user', $user);
$query->setFetchMode("JazzyTransactionBundle:MoneyTransaction", "sender", "EAGER");
$transactions = $query->execute();



WORKING:

cakper

protocol Board {
    func isValidMove(move: (x: Int, y: Int)) -> Bool
}

cakper

<VirtualHost *:80>
    DocumentRoot /mnt/project/web

    RewriteEngine On

    RewriteCond %{DOCUMENT_ROOT}/$1 !-f
    RewriteRule ^/direcory/(.*)$ /direcory/app_dev.php [QSA,L,PT]

    Alias /direcory /mnt/project/web

cakper

#!/bin/sh

CWD=$(pwd)
STATUS=0

echo "Running PHPSpec and PHPCS"

if [ -f $CWD/bin/phpspec ]
then
    $CWD/bin/phpspec run --quiet

cakper

trait CsvEncoder[A] {
  def encode(value: A): List[String]
}

def createEncoder[A](func: A => List[String]): CsvEncoder[A] = {
  new CsvEncoder[A] {
    override def encode(value: A) = func(value)
  }
}