AbstractUIThreadAwareObservableNumberValue.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.beans.InvalidationListener;
19 import javafx.beans.value.ChangeListener;
20 import javafx.beans.value.ObservableNumberValue;
21 
22 /**
23  @author Andres Almiray
24  @since 2.9.0
25  */
26 abstract class AbstractUIThreadAwareObservableNumberValue extends ObservableNumberValueDecorator implements UIThreadAware {
27     AbstractUIThreadAwareObservableNumberValue(ObservableNumberValue delegate) {
28         super(delegate);
29     }
30 
31     @Override
32     public void addListener(ChangeListener<? super Number> listener) {
33         if (listener instanceof UIThreadAware) {
34             getDelegate().addListener(listener);
35         else {
36             getDelegate().addListener(new UIThreadAwareChangeListener<>(listener));
37         }
38     }
39 
40     @Override
41     public void removeListener(ChangeListener<? super Number> listener) {
42         if (listener instanceof UIThreadAware) {
43             getDelegate().removeListener(listener);
44         else {
45             getDelegate().removeListener(new UIThreadAwareChangeListener<>(listener));
46         }
47     }
48 
49     @Override
50     public void addListener(InvalidationListener listener) {
51         if (listener instanceof UIThreadAware) {
52             getDelegate().addListener(listener);
53         else {
54             getDelegate().addListener(new UIThreadAwareInvalidationListener(listener));
55         }
56     }
57 
58     @Override
59     public void removeListener(InvalidationListener listener) {
60         if (listener instanceof UIThreadAware) {
61             getDelegate().removeListener(listener);
62         else {
63             getDelegate().removeListener(new UIThreadAwareInvalidationListener(listener));
64         }
65     }
66 }