muzzah

import io.reactivex.Completable;
import io.reactivex.schedulers.Schedulers;
import io.reactivex.subjects.PublishSubject;

public class Example {

    static class MessageLoop {

        PublishSubject subject = PublishSubject.create();