 
 (def env (onyx.api/start-env env-config))
 
-(def n-messages 100)
+(def n-messages 1000)
 
-(def batch-size 10)
+(def batch-size 100)
 
 (defn my-inc [segment]
   (prn "-->" segment)


(def workflow [[:in :inc] [:inc :out]])

(def in-chan (chan 100))

(def out-chan (chan 100))

(defmethod l-ext/inject-lifecycle-resources :in
  [_ _] {:core.async/in-chan in-chan})

(ns onyx.messaging.base-test
  (:require [clojure.core.async :refer [chan >!! <!! dropping-buffer]]
            [midje.sweet :refer :all]
            [onyx.peer.task-lifecycle-extensions :as l-ext]
            [onyx.plugin.core-async]
