我正在使用的库Message使用回调对象发出一系列对象.
interface MessageCallback {
onMessage(Message message);
}
使用某个libraryObject.setCallback(MessageCallback)调用添加回调,并使用非阻塞libraryObject.start()方法调用启动该进程.
创建Observable<Message>将发出这些对象的最佳方法是什么？
怎么libraryObject.start()阻止？