A Simple BLoC

import 'package:rxdart/rxdart.dart';

class ABloc {
  /// Input from the user
  var _inputSubject = PublishSubject<int>();
  Sink<int> get inputSink => _inputSubject.sink;

  /// Output for the user
  var _outputSubject = PublishSubject<int>();
  Stream<int> get outputStream => _outputSubject.stream;

  ABloc() {
    /// Get the input stream, add 1 and return to the view
    _inputSubject
      .stream
      .listen((value) => _outputSubject.add(value + 1));
  }
}