film42

require "nats/client"

def get_request
  start = nil
  
  NATS.start(:servers => ['nats://198.199.103.139:4222']) do
    start = Time.now
    
    NATS.subscribe('demo') do |msg, reply|
      NATS.publish(reply, "Polo!")

film42

start = nil
NATS.start(:servers => ['nats://198.199.103.139:4222']) do
  start = Time.now
  
  NATS.subscribe('demo', :queue => 'group.things') do |msg, reply|
    puts "Hitting node 1 with #{msg}"
    NATS.publish(reply, "Polo1!")
  end

  NATS.subscribe('demo', :queue => 'group.things') do |msg, reply|

film42

trait Queryable {
    fn pluralized_table_name(&self) -> String;

    fn predicates(&self) -> &Vec<String>;

    fn has_limit(&self) -> bool {
        return self.limit_value() >= 0;
    }

    fn limit_value(&self) -> i64;

film42

class EnumDeliveryType < ::Protobuf::Enum
  define :STANDARD, 1
  define :PRIORITY, 2
  define :NEXT_DAY, 3
  define :OVERNIGHT, 4
end

# # # # # # # # # # # # # PART 1 # # # # # # # # # # # # #

##

film42

Thread.new do
  trap(:TRAP) do
    ::Thread.list.each do |thread|      
      puts <<-THREAD_TRACE
                #{thread.inspect}:
                  #{thread.backtrace.try(:join, $INPUT_RECORD_SEPARATOR)}"
              THREAD_TRACE
    end
  end
end

film42

class BashQueue
  FIFO_QUEUE = '/tmp/channel'

  # Setup fifo queue called channel
  def self.ensure_setup!
    unless ::File.exist?(FIFO_QUEUE)
      `mkfifo #{FIFO_QUEUE}`
    end
  end

film42

-module(erlish).
-export([init/0, manager/1, get/1, set/2, keys/0, del/1, expire/2]).

manager(State) ->
    receive
        {get, Key, Sender} ->
            Value = case maps:is_key(Key, State) of
                        true ->
                            maps:get(Key, State);
                        _ ->

film42

$ film42@mbp ~/D/D/S/C/t/a/build (master)> 
valgrind --leak-check=full --dsymutil=yes ./avl_tree_tests
==65466== Memcheck, a memory error detector
==65466== Copyright (C) 2002-2013, and GNU GPL'd, by Julian Seward et al.
==65466== Using Valgrind-3.11.0.SVN and LibVEX; rerun with -h for copyright info
==65466== Command: ./avl_tree_tests
==65466== 
--65466-- run: /usr/bin/dsymutil "./avl_tree_tests"
Running test: Contains Tests
Malloc'd tree

film42

require 'thread'

##
## THREADING EXAMPLE
##
## Ruby's array append is not "thread safe." This means that real
## concurrency models will have collision issues. This is not a good
## thing, but we'll find we can use real threading constructs to
## protect code that isn't "thread safe." Run this code on MRI and
## then try running this in jRuby and compare the results.

film42

package id3

/**
 * Created by: film42 on: 3/6/15.
 */
object DecisionTreeUtils {

  type Vector[A] = List[A]
  type Matrix[A] = List[Vector[A]]