UIThreadAwareSetChangeListener.java
01 /*
02  * Copyright 2008-2017 the original author or authors.
03  *
04  * Licensed under the Apache License, Version 2.0 (the "License");
05  * you may not use this file except in compliance with the License.
06  * You may obtain a copy of the License at
07  *
08  *     http://www.apache.org/licenses/LICENSE-2.0
09  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package griffon.javafx.beans.binding;
17 
18 import javafx.collections.SetChangeListener;
19 
20 import javax.annotation.Nonnull;
21 
22 import static java.util.Objects.requireNonNull;
23 import static javafx.application.Platform.isFxApplicationThread;
24 import static javafx.application.Platform.runLater;
25 
26 /**
27  @author Andres Almiray
28  @since 2.9.0
29  */
30 class UIThreadAwareSetChangeListener<E> implements SetChangeListener<E>, UIThreadAware {
31     private final SetChangeListener<E> delegate;
32 
33     UIThreadAwareSetChangeListener(@Nonnull SetChangeListener<E> delegate) {
34         this.delegate = requireNonNull(delegate, "Argument 'delegate' must not be null");
35     }
36 
37     @Override
38     public void onChanged(final Change<? extends E> change) {
39         if (isFxApplicationThread()) {
40             delegate.onChanged(change);
41         else {
42             runLater(() -> onChanged(change));
43         }
44     }
45 
46     @Override
47     public boolean equals(Object o) {
48         return this == o || delegate.equals(o);
49     }
50 
51     @Override
52     public int hashCode() {
53         return delegate.hashCode();
54     }
55 
56     @Override
57     public String toString() {
58         return getClass().getName() ":" + delegate.toString();
59     }
60 }