manifold.stream.core — manifold 0.2.2

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.