added RxSet

-typedef ValueCallback<T> = Function(T v);

 import 'dart:async';
 import 'dart:async';
-
 import 'package:flutter/scheduler.dart';
 import 'package:flutter/scheduler.dart';
-import 'package:get/src/state_manager/rx/rx_callbacks.dart';
+import 'rx_typedefs.dart';
 
 
 /// This class is the foundation for all reactive (Rx) classes that makes Get
 /// This class is the foundation for all reactive (Rx) classes that makes Get
 /// so powerful.
 /// so powerful.

@@ -6,14 +6,17 @@ import 'rx_impl.dart';
 import 'rx_interface.dart';
 import 'rx_interface.dart';
 import 'rx_typedefs.dart';
 import 'rx_typedefs.dart';
 
 
+
 /// Create a list similar to `List<T>`
 /// Create a list similar to `List<T>`
 class RxList<E> implements List<E>, RxInterface<List<E>> {
 class RxList<E> implements List<E>, RxInterface<List<E>> {
   RxList([List<E> initial]) {
   RxList([List<E> initial]) {
     _list = initial;
     _list = initial;
   }
   }
 
 
+  List<E> _list = <E>[];
+
   @override
   @override
-  Iterator<E> get iterator => _list.iterator;
+  Iterator<E> get iterator => value.iterator;
 
 
   @override
   @override
   bool get isEmpty => value.isEmpty;
   bool get isEmpty => value.isEmpty;
@@ -193,8 +196,6 @@ class RxList<E> implements List<E>, RxInterface<List<E>> {
   void bindStream(Stream<Iterable<E>> stream) =>
   void bindStream(Stream<Iterable<E>> stream) =>
       stream.listen((va) => value = va);
       stream.listen((va) => value = va);
 
 
-  List<E> _list = <E>[];
-
   @override
   @override
   E get first => _list.first;
   E get first => _list.first;
 
 

+import 'dart:async';
+
+import 'package:flutter/foundation.dart';
+
+import 'rx_impl.dart';
+import 'rx_interface.dart';
+import 'rx_typedefs.dart';
+
+class RxSet<E> implements Set<E>, RxInterface<Set<E>> {
+  RxSet([Set<E> initial]) {
+    _list = initial;
+  }
+
+  RxSet<E> _list = Set<E>();
+
+  @override
+  Iterator<E> get iterator => value.iterator;
+
+  @override
+  bool get isEmpty => value.isEmpty;
+
+  bool get canUpdate {
+    return _subscriptions.length > 0;
+  }
+
+  @override
+  bool get isNotEmpty => value.isNotEmpty;
+
+  StreamController<Set<E>> subject = StreamController<Set<E>>.broadcast();
+  Map<Stream<Set<E>>, StreamSubscription> _subscriptions = Map();
+
+  /// Adds [item] only if [condition] resolves to true.
+  void addIf(condition, E item) {
+    if (condition is Condition) condition = condition();
+    if (condition is bool && condition) add(item);
+  }
+
+  /// Adds all [items] only if [condition] resolves to true.
+  void addAllIf(condition, Iterable<E> items) {
+    if (condition is Condition) condition = condition();
+    if (condition is bool && condition) addAll(items);
+  }
+
+  operator []=(int index, E val) {
+    _list[index] = val;
+    subject.add(_list);
+  }
+
+  /// Special override to push() element(s) in a reactive way
+  /// inside the List,
+  RxSet<E> operator +(Iterable<E> val) {
+    addAll(val);
+    subject.add(_list);
+    return this;
+  }
+
+  @override
+  bool add(E value) {
+    final val = _list.add(value);
+    subject.add(_list);
+    return val;
+  }
+
+  void addAll(Iterable<E> item) {
+    _list.addAll(item);
+    subject.add(_list);
+  }
+
+  /// Adds only if [item] is not null.
+  void addNonNull(E item) {
+    if (item != null) add(item);
+  }
+
+  /// Adds only if [item] is not null.
+  void addAllNonNull(Iterable<E> item) {
+    if (item != null) addAll(item);
+  }
+
+  void insert(int index, E item) {
+    _list.insert(index, item);
+    subject.add(_list);
+  }
+
+  void insertAll(int index, Iterable<E> iterable) {
+    _list.insertAll(index, iterable);
+    subject.add(_list);
+  }
+
+  int get length => value.length;
+
+  /// Removes an item from the list.
+  ///
+  /// This is O(N) in the number of items in the list.
+  ///
+  /// Returns whether the item was present in the list.
+  bool remove(Object item) {
+    bool hasRemoved = _list.remove(item);
+    if (hasRemoved) {
+      subject.add(_list);
+    }
+    return hasRemoved;
+  }
+
+  E removeAt(int index) {
+    E item = _list.removeAt(index);
+    subject.add(_list);
+    return item;
+  }
+
+  E removeLast() {
+    E item = _list.removeLast();
+    subject.add(_list);
+    return item;
+  }
+
+  void removeRange(int start, int end) {
+    _list.removeRange(start, end);
+    subject.add(_list);
+  }
+
+  void removeWhere(bool Function(E) test) {
+    _list.removeWhere(test);
+    subject.add(_list);
+  }
+
+  void clear() {
+    _list.clear();
+    subject.add(_list);
+  }
+
+  void sort([int compare(E a, E b)]) {
+    _list.sort();
+    subject.add(_list);
+  }
+
+  close() {
+    _subscriptions.forEach((observable, subscription) {
+      subscription.cancel();
+    });
+    _subscriptions.clear();
+    subject.close();
+  }
+
+  /// Replaces all existing items of this list with [item]
+  void assign(E item) {
+    clear();
+    add(item);
+  }
+
+  void update(void fn(Iterable<E> value)) {
+    fn(value);
+    subject.add(_list);
+  }
+
+  /// Replaces all existing items of this list with [items]
+  void assignAll(Iterable<E> items) {
+    clear();
+    addAll(items);
+  }
+
+  @protected
+  Set<E> get value {
+    if (getObs != null) {
+      getObs.addListener(subject.stream);
+    }
+    return _list;
+  }
+
+  String get string => value.toString();
+
+  addListener(Stream<Set<E>> rxGetx) {
+    if (_subscriptions.containsKey(rxGetx)) {
+      return;
+    }
+    _subscriptions[rxGetx] = rxGetx.listen((data) {
+      subject.add(data);
+    });
+  }
+
+  set value(Iterable<E> val) {
+    if (_list == val) return;
+    _list = val;
+    subject.add(_list);
+  }
+
+  Stream<Set<E>> get stream => subject.stream;
+
+  StreamSubscription<Set<E>> listen(void Function(Set<E>) onData,
+          {Function onError, void Function() onDone, bool cancelOnError}) =>
+      stream.listen(onData, onError: onError, onDone: onDone);
+
+  void bindStream(Stream<Iterable<E>> stream) =>
+      stream.listen((va) => value = va);
+
+  @override
+  E get first => _list.first;
+
+  @override
+  E get last => _list.last;
+
+  @override
+  bool any(bool Function(E) test) {
+    return _list.any(test);
+  }
+
+  @override
+  Set<R> cast<R>() {
+    return _list.cast<R>();
+  }
+
+  @override
+  bool contains(Object element) {
+    return _list.contains(element);
+  }
+
+  @override
+  E elementAt(int index) {
+    return _list.elementAt(index);
+  }
+
+  @override
+  bool every(bool Function(E) test) {
+    return _list.every(test);
+  }
+
+  @override
+  Iterable<T> expand<T>(Iterable<T> Function(E) f) {
+    return _list.expand(f);
+  }
+
+  @override
+  E firstWhere(bool Function(E) test, {E Function() orElse}) {
+    return _list.firstWhere(test, orElse: orElse);
+  }
+
+  @override
+  T fold<T>(T initialValue, T Function(T, E) combine) {
+    return _list.fold(initialValue, combine);
+  }
+
+  @override
+  Iterable<E> followedBy(Iterable<E> other) {
+    return _list.followedBy(other);
+  }
+
+  @override
+  void forEach(void Function(E) f) {
+    _list.forEach(f);
+  }
+
+  @override
+  String join([String separator = ""]) {
+    return _list.join(separator);
+  }
+
+  @override
+  E lastWhere(bool Function(E) test, {E Function() orElse}) {
+    return _list.lastWhere(test, orElse: orElse);
+  }
+
+  @override
+  Iterable<T> map<T>(T Function(E) f) {
+    return _list.map(f);
+  }
+
+  @override
+  E reduce(E Function(E, E) combine) {
+    return _list.reduce(combine);
+  }
+
+  @override
+  E get single => _list.single;
+
+  @override
+  E singleWhere(bool Function(E) test, {E Function() orElse}) {
+    return _list.singleWhere(test, orElse: orElse);
+  }
+
+  @override
+  Iterable<E> skip(int count) {
+    return _list.skip(count);
+  }
+
+  @override
+  Iterable<E> skipWhile(bool Function(E) test) {
+    return _list.skipWhile(test);
+  }
+
+  @override
+  Iterable<E> take(int count) {
+    return _list.take(count);
+  }
+
+  @override
+  Iterable<E> takeWhile(bool Function(E) test) {
+    return _list.takeWhile(test);
+  }
+
+  @override
+  List<E> toList({bool growable = true}) {
+    return _list.toList(growable: growable);
+  }
+
+  @override
+  Set<E> toSet() {
+    return _list.toSet();
+  }
+
+  @override
+  Iterable<E> where(bool Function(E) test) {
+    return _list.where(test);
+  }
+
+  @override
+  Iterable<T> whereType<T>() {
+    return _list.whereType<T>();
+  }
+
+  @override
+  bool containsAll(Iterable<Object> other) {
+    return _list.containsAll(other);
+  }
+
+  @override
+  Set<E> difference(Set<Object> other) {
+    return _list.difference(other);
+  }
+
+  @override
+  Set<E> intersection(Set<Object> other) {
+    return _list.intersection(other);
+  }
+
+  @override
+  E lookup(Object object) {
+    return _list.lookup(object);
+  }
+
+  @override
+  void removeAll(Iterable<Object> elements) {
+    _list.removeAll(elements);
+  }
+
+  @override
+  void retainAll(Iterable<Object> elements) {
+    _list.retainAll(elements);
+  }
+
+  @override
+  void retainWhere(bool Function(E) E) {
+    _list.retainWhere(E);
+  }
+
+  @override
+  Set<E> union(Set<E> other) {
+    return _list.union(other);
+  }
+}
+
+extension SetExtension<E> on Set<E> {
+  RxSet<E> get obs {
+    if (this != null)
+      return RxSet<E>(<E>{})..addAllNonNull(this);
+    else
+      return RxSet<E>(null);
+  }
+}

 typedef bool Condition();
 typedef bool Condition();
+typedef ValueCallback<T> = Function(T v);

 import 'package:flutter/widgets.dart';
 import 'package:flutter/widgets.dart';
-import 'package:get/src/state_manager/rx/rx_obx.dart';
+import 'package:get/src/state_manager/rx/rx_obx_widget.dart';
 import 'get_state.dart';
 import 'get_state.dart';
 
 
 class MixinBuilder<T extends GetxController> extends StatelessWidget {
 class MixinBuilder<T extends GetxController> extends StatelessWidget {

@@ -7,6 +7,7 @@ export 'src/state_manager/rx/rx_interface.dart';
 export 'src/state_manager/rx/rx_impl.dart';
 export 'src/state_manager/rx/rx_impl.dart';
 export 'src/state_manager/rx/rx_list.dart';
 export 'src/state_manager/rx/rx_list.dart';
 export 'src/state_manager/rx/rx_map.dart';
 export 'src/state_manager/rx/rx_map.dart';
-export 'src/state_manager/rx/rx_event.dart';
-export 'src/state_manager/rx/rx_obx.dart';
-export 'src/state_manager/rx/rx_getbuilder.dart';
+export 'src/state_manager/rx/rx_set.dart';
+export 'src/state_manager/rx/rx_workers.dart';
+export 'src/state_manager/rx/rx_obx_widget.dart';
+export 'src/state_manager/rx/rx_getx_widget.dart';