In RxJava, PublishSubject [http://reactivex.io/RxJava/3.x/javadoc/io/reactivex/rxjava3/subjects/PublishSubject.html] (or PublishRelay [https://github.com/JakeWharton/RxRelay] if you’re a cool kid) is a gizmo for manually pumping data into streams like in this contrived example: private val socketSubject = PublishSubject.create() fun
