@@ -0,0 +1,406 @@
+package io.reactors.japi;%0A%0A%0A%0Aimport java.util.function.Consumer;%0A%0A%0A%0Apublic abstract class Observer%3CT%3E %7B%0A  private io.reactors.Observer%3CT%3E self;%0A%0A  Observer(io.reactors.Observer%3CT%3E self) %7B%0A    this.self = self;%0A  %7D%0A%0A  public void react(T value, Object hint) %7B%0A    self.react(value, hint);%0A  %7D%0A%0A  public void except(Throwable t) %7B%0A    self.except(t);%0A  %7D%0A%0A  public void unreact() %7B%0A    self.unreact();%0A  %7D%0A%7D%0A

Add `japi` observer.