- final void removeAndCloseListener(final BaseListenerInterface listener) {
- requireNonNull(listener);
- if (listener instanceof ListenerAdapter) {
- removeAndCloseDataChangeListener((ListenerAdapter) listener);
- } else if (listener instanceof NotificationListenerAdapter) {
- removeAndCloseNotificationListener((NotificationListenerAdapter) listener);
+ final void removeAndCloseListener(final AbstractStream<?> stream) {
+ requireNonNull(stream);
+ if (stream instanceof ListenerAdapter dataChange) {
+ removeAndCloseDataChangeListener(dataChange);
+ } else if (stream instanceof NotificationListenerAdapter notification) {
+ removeAndCloseNotificationListener(notification);