From d3f1b051022e1979c9c25944c4374aa8f38622f0 Mon Sep 17 00:00:00 2001
From: Michiel Borkent <michielborkent@gmail.com>
Date: Tue, 4 Feb 2020 12:42:05 +0100
Subject: [PATCH] Make core.async.impl.protocols namespace reachable from
 within bb

---
 src/babashka/impl/async.clj | 5 ++++-
 src/babashka/main.clj       | 3 ++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/babashka/impl/async.clj b/src/babashka/impl/async.clj
index 61022448..9cfa421a 100644
--- a/src/babashka/impl/async.clj
+++ b/src/babashka/impl/async.clj
@@ -1,6 +1,7 @@
 (ns babashka.impl.async
   {:no-doc true}
-  (:require [clojure.core.async :as async]))
+  (:require [clojure.core.async :as async]
+            [clojure.core.async.impl.protocols :as protocols]))
 
 (defn thread
   [_ _ & body]
@@ -66,3 +67,5 @@
    'untap async/untap
    'untap-all async/untap-all})
 
+(def async-protocols-namespace
+  {'ReadPort protocols/ReadPort})
diff --git a/src/babashka/main.clj b/src/babashka/main.clj
index d8a623cc..eca08e65 100644
--- a/src/babashka/main.clj
+++ b/src/babashka/main.clj
@@ -1,7 +1,7 @@
 (ns babashka.main
   {:no-doc true}
   (:require
-   [babashka.impl.async :refer [async-namespace]]
+   [babashka.impl.async :refer [async-namespace async-protocols-namespace]]
    [babashka.impl.cheshire :refer [cheshire-core-namespace]]
    [babashka.impl.classes :as classes]
    [babashka.impl.classpath :as cp]
@@ -252,6 +252,7 @@ Everything after that is bound to *command-line-args*."))
    'babashka.signal {'pipe-signal-received? pipe-signal-received?}
    'clojure.java.io io-namespace
    'clojure.core.async async-namespace
+   'clojure.core.async.impl.protocols async-protocols-namespace
    'clojure.data.csv csv/csv-namespace
    'cheshire.core cheshire-core-namespace
    'clojure.stacktrace stacktrace-namespace