reactive-shipping

designed to ship packages to customer

Usage

• install lein
• setup ~/.lein/profiles.clj in case of proxy

{:user                                                                                                                                               {:repository [["artifactory-libs-releases" "https://code.shipping.com/artifactory/libs-release/"]        
                ["artifactory-libs-snapshot" "https://code.shipping.com/artifactory/libs-snapshot/"]]} 
}

;; Read each package from stdin


lein run inline-reactive
(inline)
mypackage1
mypackage1 [consumer confirms] shipment

;; or
lein run inline-reactive < input-events > output-events

;; read from input-events filestream
$ lein run default-reactive < input-events
(async)
package-1 shipped
package-2 shipped
package-4 shipped
package-7 shipped
package-5 shipped
package-6 shipped
package-3 shipped
package-8 shipped
package-13 shipped
package-9 shipped
package-14 shipped
package-15 shipped
package-11 shipped
package-16 shipped
...

License

Copyright © prayagupd

References

Chapter 9 - The Sacred Art of Concurrent and Parallel Programming

Chapter 11 - Mastering Concurrent Processes with core.async

Using core.async for Producer-consumer Systems