@@ -0,0 +1,1177 @@
+/*%0A *  Copyright 2020 by Joerg Hohwiller%0A *%0A *  Licensed under the Apache License, Version 2.0 (the %22License%22);%0A *  you may not use this file except in compliance with the License.%0A *  You may obtain a copy of the License at%0A *%0A *       http://www.apache.org/licenses/LICENSE-2.0%0A *%0A *  Unless required by applicable law or agreed to in writing, software%0A *  distributed under the License is distributed on an %22AS IS%22 BASIS,%0A *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.%0A *  See the License for the specific language governing permissions and%0A *  limitations under the License.%0A */%0Apackage org.teavm.classlib.java.util.concurrent;%0A%0A// https://www.reactive-streams.org/%0Apublic class TFlow %7B%0A%0A    public interface Processor%3CT, R%3E extends Subscriber%3CT%3E, Publisher%3CR%3E %7B%0A%0A    %7D%0A%0A    public interface Publisher%3CT%3E %7B%0A        void subscribe(Subscriber%3C? super T%3E s);%0A    %7D%0A%0A    public interface Subscriber%3CT%3E %7B%0A        void onComplete();%0A%0A        void onError%E2%80%8B(Throwable t);%0A%0A        void onNext%E2%80%8B(T t);%0A%0A        void onSubscribe%E2%80%8B(Subscription s);%0A    %7D%0A%0A    public interface Subscription %7B%0A        void cancel();%0A%0A        void request%E2%80%8B(long n);%0A    %7D%0A%0A%7D%0A

Add Flow API for reactive programming (#486)