Lines Matching defs:Observer
84 private List<Observer> mObservers = new ArrayList<>();
97 * An observer of this media source.
99 public abstract static class Observer {
103 * {@link Observer} subscribed by using {@link MediaSource#subscribe(Observer)}.
134 MediaSource.this.notify(observer -> observer.onBrowseConnected(true));
139 MediaSource.this.notify(Observer::onBrowseDisconnected);
144 MediaSource.this.notify(observer -> observer.onBrowseConnected(false));
193 public boolean subscribe(Observer observer) {
197 mObservers.add(observer);
207 observer.onBrowseConnected(true);
215 public void unsubscribe(Observer observer) {
216 mObservers.remove(observer);
516 private void notify(Consumer<Observer> notification) {
518 List<Observer> observers = new ArrayList<>(mObservers);
519 for (Observer observer : observers) {
520 notification.accept(observer);
