tpolecat

package util

import scalaz.effect.IO
import scalaz._
import Scalaz._
import scala.concurrent.stm.{ retry => stmRetry, _ }

object X {

  type STM[+A] = ReaderT[IO, InTxn, A]

jhickner

import Data.Char

strong = and . sequence conditions
  where conditions = [ (>14) . length
                     , any isUpper
                     , any isLower
                     , any isDigit
                     ]

{-

philcleveland

public class GetEventStoreEventDispatcher
{
    private const int RECONNECT_TIMEOUT_MILLISEC = 5000;
    private const int THREAD_KILL_TIMEOUT_MILLISEC = 5000;
    private const int READ_PAGE_SIZE = 500;
    private const int LIVE_QUEUE_SIZE_LIMIT = 10000;

    private readonly IEventBus _eventBus;

    private readonly EventStoreConnection _store;

haf

namespace Topshelf

[<AutoOpen>]
module Topshelf =

  open System
  open Topshelf.HostConfigurators
  open Topshelf.Runtime

  let configureTopShelf f =

Peratryn

{
    "accountWide": true, 
    "criteria": [
        {
            "description": "To Honor One's Elders", 
            "id": 7553, 
            "max": 1, 
            "orderIndex": 0
        }, 
        {

kings13y

import javax.jws.WebService
import javax.jws.soap.SOAPBinding
import javax.jws.soap.SOAPBinding.Style
import javax.xml.ws.Endpoint

@WebService(targetNamespace="org.scalabound.test", name="org.scalabound.test", portName="test", serviceName="WSTest")
private class MinimalSoapServer {

    @SOAPBinding(style = Style.RPC)
    def test(value : String) = "Hi " + value