manifold.stream.core — com.github.arohner/manifold 0.1.9-alpha5

close! clj

(close! sink)

Closes an event sink, so that it can't accept any more messages.

closed? clj

(closed? sink)

Returns true if the event sink is closed.

def-sink clj macro

(def-sink name params & body)

def-sink+source clj macro

(def-sink+source name params & body)

def-source clj macro

(def-source name params & body)

drained? clj

(drained? source)

Returns true if the event source is drained.

Sinkable clj protocol

to-sink clj

(to-sink _)

Provides a conversion mechanism to Manifold sinks.

Sourceable clj protocol

to-source clj

(to-source _)

Provides a conversion mechanism to Manifold source.

synchronous? clj

(synchronous? x)

Returns true if the underlying abstraction behaves synchronously, using thread blocking to provide backpressure.

weak-handle clj

(weak-handle x)

Returns a weak reference that can be used to construct topologies of streams.