ghadishayban

;; from 2020

(defn inputstream-on-chan
  "Adapts a channel of ByteBuffers into an InputStream
   that sources input from the ByteBuffers produced to the channel

   The producer is expected to close the channel when no more data is expected.

   Returns a map of:
     :inputstream, the InputStream

ghadishayban

{:paths ["."]
 :deps {org.clojure/clojure {:mvn/version "1.12.3"}}
 :aliases {:repro {:exec-fn repro/main}
           :accelerate {:jvm-opts ["-XX:-UseCompressedOops"]}
           
           ;; < 1.12 has a different, correct impl of LazySeqs using monitors, not RLocks
           :monitors {:deps {org.clojure/clojure {:mvn/version "1.11.4"}}}}}

ghadishayban

(ns day3
  (:require [util]))

(defn adjacent-range
  "returns [(dec lo), (inc hi)], lo clamped by 0, hi clamped by arg"
  [lo hi hi-clamp]
  [(max (dec lo) 0)
   (min (inc hi) hi-clamp)])

(defn scan-adjacent

ghadishayban

;; needs a refer-clojure exclude on iteration

(defn iteration
  "returns a channel of items given step!, a function of some (opaque continuation data) k
   step! calls can get bufsize ahead of consumption (asynchronously)

   step! - fn of k/nil to chan yielding (opaque) 'ret'

   :bufsize - buffer this many step! calls, default 1
   :some? - fn of ret -> truthy, indicating there is a value

ghadishayban

proto = <syntax> { import | package | option | message | enum | service | emptyStatement } <ws>

(* Header *)
syntax = ws "syntax" ws "=" ws ( "'proto3'" | '"proto3"' ) ws ";"

import = <ws "import" ws> [ "weak" | "public" ] <ws> strLit <ws ";">

package = <ws "package" ws> fullIdent <ws ";">

option = <ws "option" ws> optionName <ws "=" ws > constant <ws ";">

ghadishayban

(ns retry
  (:import [java.util.function Supplier]
           [java.util.concurrent CompletableFuture TimeUnit]))

(defn with-retry
  "given an op wanting retries, and a strategy for backoff,
   returns a CompletableFuture that can be waited on
  
   op takes no args
   A backoff strategy is a function of an exception, returning nil or a number of milliseconds to backoff"

ghadishayban

(import '[java.lang.reflect Method Modifier])

(set! *warn-on-reflection* true)

(defn- samsig
  "Given a SAM interface, returns the j.l.reflect.Method of the abstract method"
  [sym]
  (let [kls (resolve sym)]
    (if (and (class? kls) (.isInterface ^Class kls))
      (let [mid (fn [^Method m] [(.getName m) (vec (.getParameterTypes m))])

ghadishayban

#!/bin/bash

# author Ghadi Shayban <gshayban@gmail.com>
set -e

if [ -z ${1+x} ]
then
  echo provide an asm git sha / ref
  exit 1
fi

ghadishayban

Keybase proof

I hereby claim:

• I am ghadishayban on github.
• I am ghadi (https://keybase.io/ghadi) on keybase.
• I have a public key ASBXbzSnNB9Tcf5AU7PXtLsWEiBhS8jeuA3ZQe9kHQHN0Qo

To claim this, I am signing this object:

ghadishayban

;; lots of garbage
;;
(->> coll                        ;; original collection
     (map #(assoc % :foo :bar))  ;; intermediate Chunked collection 1
     (filter :baz)               ;; intermediate Chunked collection 2
     (map :feature)              ;; intermediate Chunked collection 3
     (into []))                  ;; reduction using #'conj over Chunked collection #3

;; -- direct reduction using transducers --