interface Subject<T>

package thx.stream

implemented by SubjectF

Methods

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