class SubjectF<T>

package thx.stream

implements Subject<T>

import thx.stream.Subject

Constructor

new (handler:Message<T> ‑> Void)

Methods

message (msg:Message<T>):Subject<T>